Repository: activemq-artemis Updated Branches: refs/heads/master 2ba90ef60 -> dca124f9a
ARTEMIS-1041 Using less time on timeouts Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/8a84b6a1 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/8a84b6a1 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/8a84b6a1 Branch: refs/heads/master Commit: 8a84b6a1a79f659103e2a3fd487a852d101a8659 Parents: 938c4ec Author: Clebert Suconic <[email protected]> Authored: Wed Mar 15 19:21:44 2017 -0400 Committer: Clebert Suconic <[email protected]> Committed: Wed Mar 15 19:25:08 2017 -0400 ---------------------------------------------------------------------- .../artemis/tests/integration/amqp/AmqpExpiredMessageTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/8a84b6a1/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java ---------------------------------------------------------------------- diff --git a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java index 0a1f382..c075be1 100644 --- a/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java +++ b/tests/integration-tests/src/test/java/org/apache/activemq/artemis/tests/integration/amqp/AmqpExpiredMessageTest.java @@ -52,7 +52,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport { // Now try and get the message AmqpReceiver receiver = session.createReceiver(getTestName()); receiver.flow(1); - AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS); + AmqpMessage received = receiver.receive(1, TimeUnit.SECONDS); assertNull(received); assertEquals(1, queueView.getMessagesExpired()); @@ -116,7 +116,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport { // Now try and get the message AmqpReceiver receiver = session.createReceiver(getTestName()); receiver.flow(1); - AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS); + AmqpMessage received = receiver.receive(1, TimeUnit.SECONDS); assertNull(received); assertEquals(1, queueView.getMessagesExpired()); @@ -215,7 +215,7 @@ public class AmqpExpiredMessageTest extends AmqpClientTestSupport { // Now try and get the message AmqpReceiver receiver = session.createReceiver(getTestName()); receiver.flow(1); - AmqpMessage received = receiver.receive(5, TimeUnit.SECONDS); + AmqpMessage received = receiver.receive(1, TimeUnit.SECONDS); assertNull(received); assertEquals(1, queueView.getMessagesExpired());
