You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2014/05/26 11:07:36 UTC
[09/13] git commit: Fixed AMQ-5160,
fixed test testNoMessageReceivedAfterUnsubscribeMQTT
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 <dh...@yahoo.com>
Authored: Tue May 13 00:45:05 2014 -0700
Committer: Dejan Bosanac <de...@nighttale.net>
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();