Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Changed timeouts to 1 minute from 30 because of occasional long runs on CI boxes. None of these tests takes more than 5 seconds on my mac

This commit is contained in:
Kevin Earls 2013-11-14 15:33:26 +01:00
parent 0a67b12c64
commit e57aeb3786
1 changed files with 15 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -44,7 +44,7 @@ public class MQTTTest extends AbstractMQTTTest {
private static final Logger LOG = LoggerFactory.getLogger(MQTTTest.class); private static final Logger LOG = LoggerFactory.getLogger(MQTTTest.class);
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAndReceiveMQTT() throws Exception { public void testSendAndReceiveMQTT() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -88,7 +88,7 @@ public class MQTTTest extends AbstractMQTTTest {
publishProvider.disconnect(); publishProvider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testUnsubscribeMQTT() throws Exception { public void testUnsubscribeMQTT() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -136,7 +136,7 @@ public class MQTTTest extends AbstractMQTTTest {
publishProvider.disconnect(); publishProvider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAtMostOnceReceiveExactlyOnce() throws Exception { public void testSendAtMostOnceReceiveExactlyOnce() throws Exception {
/** /**
* Although subscribing with EXACTLY ONCE, the message gets published * Although subscribing with EXACTLY ONCE, the message gets published
@ -159,7 +159,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAtLeastOnceReceiveExactlyOnce() throws Exception { public void testSendAtLeastOnceReceiveExactlyOnce() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -177,7 +177,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAtLeastOnceReceiveAtMostOnce() throws Exception { public void testSendAtLeastOnceReceiveAtMostOnce() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -195,7 +195,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAndReceiveAtMostOnce() throws Exception { public void testSendAndReceiveAtMostOnce() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -213,7 +213,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAndReceiveAtLeastOnce() throws Exception { public void testSendAndReceiveAtLeastOnce() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -231,7 +231,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAndReceiveExactlyOnce() throws Exception { public void testSendAndReceiveExactlyOnce() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -253,7 +253,7 @@ public class MQTTTest extends AbstractMQTTTest {
publisher.disconnect(); publisher.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendAndReceiveLargeMessages() throws Exception { public void testSendAndReceiveLargeMessages() throws Exception {
byte[] payload = new byte[1024 * 32]; byte[] payload = new byte[1024 * 32];
for (int i = 0; i < payload.length; i++){ for (int i = 0; i < payload.length; i++){
@ -280,7 +280,7 @@ public class MQTTTest extends AbstractMQTTTest {
publisher.disconnect(); publisher.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendMQTTReceiveJMS() throws Exception { public void testSendMQTTReceiveJMS() throws Exception {
addMQTTConnector(); addMQTTConnector();
TransportConnector openwireTransport = brokerService.addConnector("tcp://localhost:0"); TransportConnector openwireTransport = brokerService.addConnector("tcp://localhost:0");
@ -309,7 +309,7 @@ public class MQTTTest extends AbstractMQTTTest {
provider.disconnect(); provider.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testSendJMSReceiveMQTT() throws Exception { public void testSendJMSReceiveMQTT() throws Exception {
addMQTTConnector(); addMQTTConnector();
TransportConnector openwireTransport = brokerService.addConnector("tcp://localhost:0"); TransportConnector openwireTransport = brokerService.addConnector("tcp://localhost:0");
@ -337,7 +337,7 @@ public class MQTTTest extends AbstractMQTTTest {
activeMQConnection.close(); activeMQConnection.close();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testPingKeepsInactivityMonitorAlive() throws Exception { public void testPingKeepsInactivityMonitorAlive() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();
@ -358,7 +358,7 @@ public class MQTTTest extends AbstractMQTTTest {
connection.disconnect(); connection.disconnect();
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testTurnOffInactivityMonitor()throws Exception{ public void testTurnOffInactivityMonitor()throws Exception{
addMQTTConnector("transport.useInactivityMonitor=false"); addMQTTConnector("transport.useInactivityMonitor=false");
brokerService.start(); brokerService.start();
@ -466,7 +466,7 @@ public class MQTTTest extends AbstractMQTTTest {
assertEquals("Should have received " + topics.length + " messages", topics.length, received); assertEquals("Should have received " + topics.length + " messages", topics.length, received);
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testReceiveMessageSentWhileOffline() throws Exception { public void testReceiveMessageSentWhileOffline() throws Exception {
byte[] payload = new byte[1024 * 32]; byte[] payload = new byte[1024 * 32];
for (int i = 0; i < payload.length; i++){ for (int i = 0; i < payload.length; i++){
@ -560,7 +560,7 @@ public class MQTTTest extends AbstractMQTTTest {
})); }));
} }
@Test(timeout=300000) @Test(timeout=60 * 1000)
public void testReuseConnection() throws Exception { public void testReuseConnection() throws Exception {
addMQTTConnector(); addMQTTConnector();
brokerService.start(); brokerService.start();