http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/205c976c/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/TextMessageIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/TextMessageIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/TextMessageIntegrationTest.java index 96f0924..20163a5 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/TextMessageIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/TextMessageIntegrationTest.java @@ -53,7 +53,7 @@ import org.junit.Test; public class TextMessageIntegrationTest extends QpidJmsTestCase { private final IntegrationTestFixture testFixture = new IntegrationTestFixture(); - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSendTextMessage() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer();) { Connection connection = testFixture.establishConnecton(testPeer); @@ -82,7 +82,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageWithContentAmqpValue() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer();) { Connection connection = testFixture.establishConnecton(testPeer); @@ -110,7 +110,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testSendTextMessageWithoutContent() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer();) { Connection connection = testFixture.establishConnecton(testPeer); @@ -138,7 +138,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageWithAmqpValueNullBodyAndNoMsgTypeAnnotation() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer();) { Connection connection = testFixture.establishConnecton(testPeer); @@ -165,7 +165,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { } } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeTextPlainNoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-8"); @@ -173,7 +173,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { doReceiveTextMessageUsingDataSectionTestImpl("text/plain", sentBytes, expectedString); } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeTextPlainCharsetUtf8NoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-8"); @@ -181,7 +181,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { doReceiveTextMessageUsingDataSectionTestImpl("text/plain;charset=utf-8", sentBytes, expectedString); } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeTextPlainCharsetUtf16NoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-16"); @@ -189,7 +189,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { doReceiveTextMessageUsingDataSectionTestImpl("text/plain;charset=utf-16", sentBytes, expectedString); } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeTextOtherNoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-8"); @@ -197,7 +197,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { doReceiveTextMessageUsingDataSectionTestImpl("text/other", sentBytes, expectedString); } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeApplicationJsonNoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-8"); @@ -205,7 +205,7 @@ public class TextMessageIntegrationTest extends QpidJmsTestCase { doReceiveTextMessageUsingDataSectionTestImpl("application/json", sentBytes, expectedString); } - @Test(timeout = 5000) + @Test(timeout = 20000) public void testReceiveTextMessageUsingDataSectionWithContentTypeApplicationXmlNoTypeAnnotation() throws Exception { String expectedString = "expectedContent"; final byte[] sentBytes = expectedString.getBytes("UTF-8");
http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/205c976c/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactoryTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactoryTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactoryTest.java index 8ec53fd..c68559e 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactoryTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderFactoryTest.java @@ -54,26 +54,26 @@ public class AmqpProviderFactoryTest extends QpidJmsTestCase { } } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testGetName() throws IOException, Exception { AmqpProviderFactory factory = new AmqpProviderFactory(); assertEquals("AMQP", factory.getName()); } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testCreateProvider() throws IOException, Exception { Provider provider = AmqpProviderFactory.create(peerURI); assertNotNull(provider); assertTrue(provider instanceof AmqpProvider); } - @Test(timeout = 10000, expected=IllegalArgumentException.class) + @Test(timeout = 20000, expected=IllegalArgumentException.class) public void testCreateProviderFailsWithBadOption() throws IOException, Exception { URI badOptionsURI = new URI(peerURI.toString() + "?amqp.badOption=true"); AmqpProviderFactory.create(badOptionsURI); } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testCreateProviderHasDefaultIdleTimeoutValue() throws IOException, Exception { Provider provider = AmqpProviderFactory.create(new URI(peerURI.toString())); assertNotNull(provider); @@ -83,7 +83,7 @@ public class AmqpProviderFactoryTest extends QpidJmsTestCase { assertTrue("No default idle timeout", amqpProvider.getIdleTimeout() > 0); } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testCreateProviderAppliesIdleTimeoutURIOption() throws IOException, Exception { int timeout = 54321; Provider provider = AmqpProviderFactory.create(new URI(peerURI.toString() + "?amqp.idleTimeout=" + timeout)); @@ -94,7 +94,7 @@ public class AmqpProviderFactoryTest extends QpidJmsTestCase { assertEquals("idle timeout option was not applied", timeout, amqpProvider.getIdleTimeout()); } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testCreateProviderAppliesOptions() throws IOException, Exception { URI configuredURI = new URI(peerURI.toString() + "?amqp.presettleConsumers=true" + @@ -115,7 +115,7 @@ public class AmqpProviderFactoryTest extends QpidJmsTestCase { assertEquals(32, amqpProvider.getChannelMax()); } - @Test(timeout = 10000) + @Test(timeout = 20000) public void testCreateProviderAppliesPresettleOption() throws IOException, Exception { URI configuredURI = new URI(peerURI.toString() + "?amqp.presettle=true"); Provider provider = AmqpProviderFactory.create(configuredURI); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/205c976c/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderTest.java index b339ad9..dea89e9 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/provider/amqp/AmqpProviderTest.java @@ -71,19 +71,19 @@ public class AmqpProviderTest extends QpidJmsTestCase { } } - @Test(timeout=10000) + @Test(timeout=20000) public void testCreate() { provider = new AmqpProvider(peerURI); assertFalse(provider.isPresettleConsumers()); } - @Test(timeout=10000, expected=RuntimeException.class) + @Test(timeout=20000, expected=RuntimeException.class) public void testGetMessageFactoryTrowsWhenNotConnected() { provider = new AmqpProvider(peerURI); provider.getMessageFactory(); } - @Test(timeout=10000) + @Test(timeout=20000) public void testConnectWithUnknownProtocol() throws Exception { provider = new AmqpProvider(peerURI); provider.setTransportType("ftp"); @@ -94,7 +94,7 @@ public class AmqpProviderTest extends QpidJmsTestCase { } } - @Test(timeout=10000) + @Test(timeout=20000) public void testConnectThrowsWhenNoPeer() throws Exception { provider = new AmqpProvider(peerURI); testPeer.close(); @@ -105,7 +105,7 @@ public class AmqpProviderTest extends QpidJmsTestCase { } } - @Test(timeout=10000) + @Test(timeout=20000) public void testStartThrowsIfNoListenerSet() throws Exception { provider = new AmqpProvider(peerURI); provider.connect(); @@ -117,7 +117,7 @@ public class AmqpProviderTest extends QpidJmsTestCase { } } - @Test(timeout=10000) + @Test(timeout=20000) public void testToString() throws IOException { provider = new AmqpProvider(peerURI); provider.connect(); @@ -125,7 +125,7 @@ public class AmqpProviderTest extends QpidJmsTestCase { assertTrue(provider.toString().contains(String.valueOf(peerURI.getPort()))); } - @Test(timeout=10000) + @Test(timeout=20000) public void testClosedProviderThrowsIOException() throws IOException { provider = new AmqpProvider(peerURI); provider.connect(); @@ -148,7 +148,7 @@ public class AmqpProviderTest extends QpidJmsTestCase { } catch (IOException ex) {} } - @Test(timeout=10000) + @Test(timeout=20000) public void testTimeoutsSetFromConnectionInfo() throws IOException, JMSException { final long CONNECT_TIMEOUT = TimeUnit.SECONDS.toMillis(4); final long CLOSE_TIMEOUT = TimeUnit.SECONDS.toMillis(5); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
