diff --git a/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverScaleDownExample.java b/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverScaleDownExample.java index 29f54c3207..147f65b6f1 100644 --- a/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverScaleDownExample.java +++ b/examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverScaleDownExample.java @@ -97,7 +97,8 @@ public class ColocatedFailoverScaleDownExample // Step 7. Crash server #0, the live server, and wait a little while to make sure // it has really crashed ServerUtil.killServer(server0); - Thread.sleep(5000); + System.out.println("Waiting for scale-down to complete..."); + Thread.sleep(10000); // Step 8. start the connection ready to receive messages connection1.start(); diff --git a/examples/jms/colocated-failover/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverExample.java b/examples/jms/colocated-failover/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverExample.java index ad62419bf8..c5bb765c46 100644 --- a/examples/jms/colocated-failover/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverExample.java +++ b/examples/jms/colocated-failover/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverExample.java @@ -97,6 +97,7 @@ public class ColocatedFailoverExample // Step 7. Crash server #0, the live server, and wait a little while to make sure // it has really crashed ServerUtil.killServer(server0); + Thread.sleep(10000); // Step 8. start the connection ready to receive messages connection.start(); diff --git a/examples/jms/colocated-failover/src/main/resources/activemq/server0/broker.xml b/examples/jms/colocated-failover/src/main/resources/activemq/server0/broker.xml index b38d7647fe..0a4103fe52 100644 --- a/examples/jms/colocated-failover/src/main/resources/activemq/server0/broker.xml +++ b/examples/jms/colocated-failover/src/main/resources/activemq/server0/broker.xml @@ -89,7 +89,9 @@ under the License. true - + + true + diff --git a/examples/jms/colocated-failover/src/main/resources/activemq/server1/broker.xml b/examples/jms/colocated-failover/src/main/resources/activemq/server1/broker.xml index f0dd08894b..8083f2760b 100644 --- a/examples/jms/colocated-failover/src/main/resources/activemq/server1/broker.xml +++ b/examples/jms/colocated-failover/src/main/resources/activemq/server1/broker.xml @@ -86,8 +86,12 @@ under the License. 2000 1 true - - + + true + + + true +