add timeouts to tests
Project: http://git-wip-us.apache.org/repos/asf/qpid-jms/repo Commit: http://git-wip-us.apache.org/repos/asf/qpid-jms/commit/e44c2e78 Tree: http://git-wip-us.apache.org/repos/asf/qpid-jms/tree/e44c2e78 Diff: http://git-wip-us.apache.org/repos/asf/qpid-jms/diff/e44c2e78 Branch: refs/heads/master Commit: e44c2e78f565d5eab6821304e3589e880774ba00 Parents: 735c219 Author: Robert Gemmell <[email protected]> Authored: Fri Oct 3 10:16:50 2014 +0100 Committer: Robert Gemmell <[email protected]> Committed: Fri Oct 3 10:16:50 2014 +0100 ---------------------------------------------------------------------- .../qpid/jms/integration/BytesMessageIntegrationTest.java | 8 ++++---- .../qpid/jms/integration/MapMessageIntegrationTest.java | 4 ++-- 2 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e44c2e78/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/BytesMessageIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/BytesMessageIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/BytesMessageIntegrationTest.java index 1c5648d..41a92dd 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/BytesMessageIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/BytesMessageIntegrationTest.java @@ -55,7 +55,7 @@ import org.junit.Test; public class BytesMessageIntegrationTest extends QpidJmsTestCase { private final IntegrationTestFixture _testFixture = new IntegrationTestFixture(); - @Test + @Test(timeout = 5000) public void testSendBasicBytesMessageWithContent() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); @@ -88,7 +88,7 @@ public class BytesMessageIntegrationTest extends QpidJmsTestCase { } } - @Test + @Test(timeout = 5000) public void testReceiveBasicBytesMessageWithContentUsingDataSection() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); @@ -134,7 +134,7 @@ public class BytesMessageIntegrationTest extends QpidJmsTestCase { * resent that it results in the expected AMQP data body section and properties content type * being received by the test peer. */ - @Test + @Test(timeout = 5000) public void testReceiveBytesMessageAndResendAfterResetAndPartialRead() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); @@ -242,7 +242,7 @@ public class BytesMessageIntegrationTest extends QpidJmsTestCase { * AMQP message containing a data body section and content type of * {@link AmqpMessageSupport.OCTET_STREAM_CONTENT_TYPE} */ - @Test + @Test(timeout = 5000) public void testReceiveBytesMessageWithAmqpValueAndResendResultsInData() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); http://git-wip-us.apache.org/repos/asf/qpid-jms/blob/e44c2e78/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MapMessageIntegrationTest.java ---------------------------------------------------------------------- diff --git a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MapMessageIntegrationTest.java b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MapMessageIntegrationTest.java index 40022da..91b5965 100644 --- a/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MapMessageIntegrationTest.java +++ b/qpid-jms-client/src/test/java/org/apache/qpid/jms/integration/MapMessageIntegrationTest.java @@ -58,7 +58,7 @@ public class MapMessageIntegrationTest extends QpidJmsTestCase { * a map which holds entries of the various supported entry types is returned as a * {@link MapMessage}, and verify the values can all be retrieved as expected. */ - @Test + @Test(timeout = 5000) public void testReceiveBasicMapMessage() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); @@ -147,7 +147,7 @@ public class MapMessageIntegrationTest extends QpidJmsTestCase { * This doesn't happen in the above test as the reversed roles mean it is protons DecoderImpl doing the decoding * and it does a similarly ugly cast on the integer value to char before output. */ - @Test + @Test(timeout = 5000) public void testSendBasicMapMessage() throws Exception { try (TestAmqpPeer testPeer = new TestAmqpPeer(IntegrationTestFixture.PORT);) { Connection connection = _testFixture.establishConnecton(testPeer); --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
