Fixed AMQ-5160, fixed test testNoMessageReceivedAfterUnsubscribeMQTT
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/70f7c580 Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/70f7c580 Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/70f7c580 Branch: refs/heads/trunk Commit: 70f7c5805c0a39034fd1f4f9b76b6e7b293b33ed Parents: 0a39782 Author: Dhiraj Bokde <[email protected]> Authored: Tue May 13 00:45:05 2014 -0700 Committer: Dejan Bosanac <[email protected]> Committed: Mon May 26 11:07:19 2014 +0200 ---------------------------------------------------------------------- .../src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java | 2 -- 1 file changed, 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq/blob/70f7c580/activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java ---------------------------------------------------------------------- diff --git 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 index 3c0701e..9c8c9b5 100644 --- 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();
