From 8a84b6a1a79f659103e2a3fd487a852d101a8659 Mon Sep 17 00:00:00 2001 From: Clebert Suconic Date: Wed, 15 Mar 2017 19:21:44 -0400 Subject: [PATCH] ARTEMIS-1041 Using less time on timeouts --- .../tests/integration/amqp/AmqpExpiredMessageTest.java | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) 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 0a1f382b91..c075be1dfc 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());