From 0cf31ae36404ddcc487ad4f392c4abb692151522 Mon Sep 17 00:00:00 2001 From: andrea Date: Wed, 28 Aug 2013 22:27:41 +0200 Subject: [PATCH] Moved testUnsubscribe_do_not_notify_anymore_same_session from custome API to Fuse's --- .../server/ServerIntegrationFuseTest.java | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) diff --git a/broker/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java b/broker/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java index 25a2c54a..ded1696e 100644 --- a/broker/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java +++ b/broker/src/test/java/org/dna/mqtt/moquette/server/ServerIntegrationFuseTest.java @@ -174,6 +174,25 @@ public class ServerIntegrationFuseTest { assertEquals("/topic", msg.getTopic()); } + @Test + public void testUnsubscribe_do_not_notify_anymore_same_session() throws Exception { + m_connection = m_mqtt.blockingConnection(); + m_connection.connect(); + m_connection.subscribe(new Topic[] {new Topic("/topic", QoS.AT_MOST_ONCE)}); + m_connection.publish("/topic", "Test my payload".getBytes(), QoS.AT_MOST_ONCE, false); + //check message received + Message msg = m_connection.receive(); + msg.ack(); + assertEquals("/topic", msg.getTopic()); + + String[] topics = new String[] {"/topic"}; + m_connection.unsubscribe(topics); + + m_connection.publish("/topic", "Test my payload".getBytes(), QoS.AT_MOST_ONCE, false); + msg = m_connection.receive(1, TimeUnit.SECONDS); + assertNull(msg); + } + @Test public void testUnsubscribe_do_not_notify_anymore_new_session() throws Exception { m_connection = m_mqtt.blockingConnection();