Convert test_retained_removed to native test client

Wiebe Cazemier
1 parent 0765167b
Showing 1 changed file with 19 additions and 11 deletions
FlashMQTests/tst_maintests.cpp
@@ -491,23 +491,31 @@ void MainTests::test_retained_changed()
 void MainTests::test_retained_removed()
 {
-    TwoClientTestContext testContext;
+    FlashMQTestClient sender;
+    FlashMQTestClient receiver;
-    QByteArray payload = "We are testing";
-    QString topic = "retaintopic";
+    sender.start();
+    receiver.start();
-    testContext.connectSender();
-    testContext.publish(topic, payload, true);
+    std::string payload = "We are testing";
+    std::string topic = "retaintopic";
-    payload = "";
+    sender.connectClient(ProtocolVersion::Mqtt311);
-    testContext.publish(topic, payload, true);
+    Publish pub1(topic, payload, 0);
+    pub1.retain = true;
+    sender.publish(pub1);
-    testContext.connectReceiver();
-    testContext.subscribeReceiver(topic);
-    testContext.waitReceiverReceived(0);
+    pub1.payload = "";
+
+    sender.publish(pub1);
+
+    receiver.connectClient(ProtocolVersion::Mqtt311);
+    receiver.subscribe(topic, 0);
+    usleep(100000);
+    receiver.waitForMessageCount(0);
-    QVERIFY2(testContext.receivedMessages.empty(), "We erased the retained message. We shouldn't have received any.");
+    QVERIFY2(receiver.receivedPublishes.empty(), "We erased the retained message. We shouldn't have received any.");
 }
 /**