Apache/activemq
1
0
Fork 0
mirror of https://github.com/apache/activemq.git synced 2025-02-16 23:16:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

No point in waiting around for 5 seconds to prove that nothing will be received. 4 minutes off tests.

Browse Source
This commit is contained in:
Daniel Kulp 2014-07-18 11:15:36 -04:00
parent 3653f81b5b
commit 4de5219a8f
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
activemq-mqtt/src/test/java/org/apache/activemq/transport/mqtt/MQTTTest.java
View File

@ -553,7 +553,7 @@ public class MQTTTest extends AbstractMQTTTest {
assertNotNull("No retained message for " + clientId, msg); assertNotNull("No retained message for " + clientId, msg);
assertEquals(RETAIN, new String(msg.getPayload())); assertEquals(RETAIN, new String(msg.getPayload()));
msg.ack(); msg.ack();
assertNull(connection.receive(5000, TimeUnit.MILLISECONDS)); assertNull(connection.receive(500, TimeUnit.MILLISECONDS));
// test duplicate subscription // test duplicate subscription
connection.subscribe(new Topic[]{new Topic(TOPICA, QoS.AT_LEAST_ONCE)}); connection.subscribe(new Topic[]{new Topic(TOPICA, QoS.AT_LEAST_ONCE)});
@ -561,13 +561,13 @@ public class MQTTTest extends AbstractMQTTTest {
assertNotNull("No retained message on duplicate subscription for " + clientId, msg); assertNotNull("No retained message on duplicate subscription for " + clientId, msg);
assertEquals(RETAIN, new String(msg.getPayload())); assertEquals(RETAIN, new String(msg.getPayload()));
msg.ack(); msg.ack();
assertNull(connection.receive(5000, TimeUnit.MILLISECONDS)); assertNull(connection.receive(500, TimeUnit.MILLISECONDS));
connection.unsubscribe(new String[]{"TopicA"}); connection.unsubscribe(new String[]{"TopicA"});
// clear retained message and check that we don't receive it // clear retained message and check that we don't receive it
connection.publish(TOPICA, "".getBytes(), QoS.AT_MOST_ONCE, true); connection.publish(TOPICA, "".getBytes(), QoS.AT_MOST_ONCE, true);
connection.subscribe(new Topic[]{new Topic(TOPICA, QoS.AT_LEAST_ONCE)}); connection.subscribe(new Topic[]{new Topic(TOPICA, QoS.AT_LEAST_ONCE)});
msg = connection.receive(5000, TimeUnit.MILLISECONDS); msg = connection.receive(500, TimeUnit.MILLISECONDS);
assertNull("Retained message not cleared for " + clientId, msg); assertNull("Retained message not cleared for " + clientId, msg);
connection.unsubscribe(new String[]{"TopicA"}); connection.unsubscribe(new String[]{"TopicA"});
@ -578,7 +578,7 @@ public class MQTTTest extends AbstractMQTTTest {
assertNotNull("No reset retained message for " + clientId, msg); assertNotNull("No reset retained message for " + clientId, msg);
assertEquals(RETAIN, new String(msg.getPayload())); assertEquals(RETAIN, new String(msg.getPayload()));
msg.ack(); msg.ack();
assertNull(connection.receive(5000, TimeUnit.MILLISECONDS)); assertNull(connection.receive(500, TimeUnit.MILLISECONDS));
// re-connect and check // re-connect and check
connection.disconnect(); connection.disconnect();
@ -589,7 +589,7 @@ public class MQTTTest extends AbstractMQTTTest {
assertNotNull("No reset retained message for " + clientId, msg); assertNotNull("No reset retained message for " + clientId, msg);
assertEquals(RETAIN, new String(msg.getPayload())); assertEquals(RETAIN, new String(msg.getPayload()));
msg.ack(); msg.ack();
assertNull(connection.receive(5000, TimeUnit.MILLISECONDS)); assertNull(connection.receive(500, TimeUnit.MILLISECONDS));
connection.unsubscribe(new String[]{"TopicA"}); connection.unsubscribe(new String[]{"TopicA"});