NO-JIRA Adjust slow consumer example timing
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/e9991838 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/e9991838 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/e9991838 Branch: refs/heads/master Commit: e9991838c88a62dd5e567d633bddea7fe89c99d4 Parents: b638748 Author: Justin Bertram <jbert...@apache.org> Authored: Tue Mar 6 11:31:25 2018 -0600 Committer: Clebert Suconic <clebertsuco...@apache.org> Committed: Tue Mar 6 12:39:43 2018 -0500 ---------------------------------------------------------------------- .../activemq/artemis/jms/example/KillSlowConsumerExample.java | 5 ++--- .../activemq/artemis/jms/example/NotifySlowConsumerExample.java | 2 -- .../src/main/resources/activemq/server0/broker.xml | 4 ++-- 3 files changed, 4 insertions(+), 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/e9991838/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/KillSlowConsumerExample.java ---------------------------------------------------------------------- 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 3b0f683..867b87d 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 { } } } - } } http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/e9991838/examples/features/standard/slow-consumer/src/main/java/org/apache/activemq/artemis/jms/example/NotifySlowConsumerExample.java ---------------------------------------------------------------------- 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 cc713a7..22c2ba9 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 http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/e9991838/examples/features/standard/slow-consumer/src/main/resources/activemq/server0/broker.xml ---------------------------------------------------------------------- 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 c8c927a..ec8797c 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. <address-setting match="slow.consumer.kill"> <slow-consumer-threshold>10</slow-consumer-threshold> <slow-consumer-policy>KILL</slow-consumer-policy> - <slow-consumer-check-period>5</slow-consumer-check-period> + <slow-consumer-check-period>3</slow-consumer-check-period> </address-setting> <address-setting match="slow.consumer.notify"> <slow-consumer-threshold>10</slow-consumer-threshold> <slow-consumer-policy>NOTIFY</slow-consumer-policy> - <slow-consumer-check-period>5</slow-consumer-check-period> + <slow-consumer-check-period>3</slow-consumer-check-period> </address-setting> </address-settings>
