Moved testCleanSession_maintainClientSubscriptions_withServerRestart from custome API to Fuse's

2013-08-28 22:04:45 +02:00
parent cdf76080c5
commit 8c04526c62
1 changed files with 26 additions and 0 deletions
@@ -132,6 +132,32 @@ public class ServerIntegrationFuseTest {
        assertNull(msg);
    }
    
+    @Test
+    public void testCleanSession_maintainClientSubscriptions_withServerRestart() throws Exception {
+        MQTT localMqtt = new MQTT(m_mqtt);
+        localMqtt.setCleanSession(false);
+        BlockingConnection connection = localMqtt.blockingConnection();
+        connection.connect();
+        Topic[] topics = {new Topic("/topic", QoS.AT_MOST_ONCE)};
+        connection.subscribe(topics);
+        connection.disconnect();
+        
+        m_server.stopServer();
+        
+        m_server.startServer();
+        
+        //the client reconnects but with cleanSession = true and publish
+        MQTT anotherLocalMqtt = new MQTT(m_mqtt);
+        anotherLocalMqtt.setCleanSession(false);
+        BlockingConnection anotherconnection = localMqtt.blockingConnection();
+        anotherconnection.connect();
+        anotherconnection.publish("/topic", "Test my payload".getBytes(), QoS.AT_MOST_ONCE, false);
+        
+        //Verify that the message is published due to prevoius subscription
+        Message msg = anotherconnection.receive(1, TimeUnit.SECONDS);
+        assertEquals("/topic", msg.getTopic());
+    }
+    
    @Test
    public void testPublishWithQoS1() throws Exception {
        m_connection = m_mqtt.blockingConnection();