diff --git a/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java b/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java index 3b0f6834d3..867b87d50b 100644 --- a/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java +++ b/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java @@ -34,12 +34,12 @@ import org.apache.activemq.artemis.api.core.ActiveMQObjectClosedException; * * - sends messages to a queue "slow.consumer.kill". * - starts a consumer BUT does not consume any messages. - * - waits for 8 seconds and tries to consume a message. + * - waits for 10 seconds and tries to consume a message. * - receive an exception as the connection should already be closed. */ public class KillSlowConsumerExample { - public static final int WAIT_TIME = 7; + public static final int WAIT_TIME = 10; public static void main(final String[] args) throws Exception { @@ -98,7 +98,6 @@ public class KillSlowConsumerExample { } } } - } } diff --git a/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java b/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java index cc713a7f99..22c2ba9052 100644 --- a/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java +++ b/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java @@ -103,8 +103,6 @@ public class NotifySlowConsumerExample { if (!isNotified) { throw new RuntimeException("SlowConsumerExample.demoSlowConsumerNotify() FAILED; timeout occurred before" + " - slow consumer notification was received. "); } - } - } } \ No newline at end of file diff --git a/examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml b/examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml index c8c927ae72..ec8797c69b 100644 --- a/examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml +++ b/examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml @@ -52,13 +52,13 @@ under the License. 10 KILL - 5 + 3 10 NOTIFY - 5 + 3