diff options
| author | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-19 16:03:56 +0200 |
|---|---|---|
| committer | Oskari Timperi <oskari.timperi@iki.fi> | 2017-02-19 16:03:56 +0200 |
| commit | 8198f6d6beb3c8af3768236070089112c094b92e (patch) | |
| tree | 7dcddfde2133850077ec8dc34bc9264fcb4e469a /test/interop/overlapping_subscriptions_test.c | |
| parent | e6e625ed6c1300e382a36b9ebef48336a55550e9 (diff) | |
| download | mqtt-8198f6d6beb3c8af3768236070089112c094b92e.tar.gz mqtt-8198f6d6beb3c8af3768236070089112c094b92e.zip | |
Add MqttClientSubscribeMany() and make necessary API changes
Diffstat (limited to 'test/interop/overlapping_subscriptions_test.c')
| -rw-r--r-- | test/interop/overlapping_subscriptions_test.c | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/test/interop/overlapping_subscriptions_test.c b/test/interop/overlapping_subscriptions_test.c index c6e5da0..ec6f061 100644 --- a/test/interop/overlapping_subscriptions_test.c +++ b/test/interop/overlapping_subscriptions_test.c @@ -7,11 +7,12 @@ TEST overlapping_subscriptions_test() { TestClient *client; int count; + const char *mywildtopics[] = { wildtopics[6], wildtopics[0] }; + int qos[] = { 2, 1 }; client = TestClientNew("clienta"); ASSERT(TestClientConnect(client, "localhost", 1883, 60, 1)); - ASSERT(TestClientSubscribe(client, wildtopics[6], 2)); - ASSERT(TestClientSubscribe(client, wildtopics[0], 1)); + ASSERT(TestClientSubscribeMany(client, mywildtopics, qos, 2)); ASSERT(TestClientPublish(client, 2, 0, topics[3], "overlapping topic filters")); ASSERT(TestClientWait(client, 1000)); |