Fixed AMQ-5160, fixed test testNoMessageReceivedAfterUnsubscribeMQTT

2014-05-13 00:45:05 -07:00 · 2014-05-13 00:45:05 -07:00 · 70f7c5805c
parent 0a39782bf5
commit 70f7c5805c
1 changed files with 0 additions and 2 deletions
--- a/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
+++ b/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
@ -1371,8 +1371,6 @@ public class MQTTTest extends AbstractMQTTTest {
        }

        // these should not be received
-        connectionSub = mqttSub.blockingConnection();
-        connectionSub.connect();
        assertNull(connectionSub.receive(5, TimeUnit.SECONDS));

        connectionSub.disconnect();