aboutsummaryrefslogtreecommitdiff
path: root/test/interop/unsubscribe_test.c
diff options
context:
space:
mode:
authorOskari Timperi <oskari.timperi@iki.fi>2017-03-06 21:31:07 +0200
committerOskari Timperi <oskari.timperi@iki.fi>2017-03-06 21:31:07 +0200
commita062d934aef40829d9559a8ca83147ea4c44108e (patch)
tree6ee1f9eb3208bea65365e63d039ad27c40111c6f /test/interop/unsubscribe_test.c
parente9958e8a0f5aa5fbe0a4a03be42b8bf640add6f7 (diff)
downloadmqtt-a062d934aef40829d9559a8ca83147ea4c44108e.tar.gz
mqtt-a062d934aef40829d9559a8ca83147ea4c44108e.zip
Massive refactoring of the internals
Diffstat (limited to 'test/interop/unsubscribe_test.c')
-rw-r--r--test/interop/unsubscribe_test.c31
1 files changed, 31 insertions, 0 deletions
diff --git a/test/interop/unsubscribe_test.c b/test/interop/unsubscribe_test.c
new file mode 100644
index 0000000..a7e4668
--- /dev/null
+++ b/test/interop/unsubscribe_test.c
@@ -0,0 +1,31 @@
+#include "greatest.h"
+#include "testclient.h"
+#include "cleanup.c"
+#include "topics.c"
+
+TEST unsubscribe_test()
+{
+ TestClient *client;
+
+ client = TestClientNew("clienta");
+ ASSERT(TestClientConnect(client, "localhost", 1883, 60, 1));
+ ASSERT(TestClientSubscribe(client, topics[0], 2));
+ ASSERT(TestClientPublish(client, 2, 0, topics[0], "msg"));
+ ASSERT(TestClientUnsubscribe(client, topics[0]));
+ ASSERT(TestClientPublish(client, 2, 0, topics[0], "msg"));
+ TestClientDisconnect(client);
+ ASSERT_EQ(1, TestClientMessageCount(client));
+ TestClientFree(client);
+
+ PASS();
+}
+
+GREATEST_MAIN_DEFS();
+
+int main(int argc, char **argv)
+{
+ GREATEST_MAIN_BEGIN();
+ cleanup();
+ RUN_TEST(unsubscribe_test);
+ GREATEST_MAIN_END();
+}