Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix failing colocated examples

This commit is contained in:
jbertram 2015-07-29 16:53:44 -05:00 committed by Clebert Suconic
parent fe95e34390
commit df075c423f
4 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
examples/jms/colocated-failover-scale-down/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverScaleDownExample.java
View File

@ -97,7 +97,8 @@ public class ColocatedFailoverScaleDownExample
// Step 7. Crash server #0, the live server, and wait a little while to make sure // Step 7. Crash server #0, the live server, and wait a little while to make sure
// it has really crashed // it has really crashed
ServerUtil.killServer(server0); 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 // Step 8. start the connection ready to receive messages
connection1.start(); connection1.start();

1
examples/jms/colocated-failover/src/main/java/org/apache/activemq/artemis/jms/example/ColocatedFailoverExample.java
View File

@ -97,6 +97,7 @@ public class ColocatedFailoverExample
// Step 7. Crash server #0, the live server, and wait a little while to make sure // Step 7. Crash server #0, the live server, and wait a little while to make sure
// it has really crashed // it has really crashed
ServerUtil.killServer(server0); ServerUtil.killServer(server0);
Thread.sleep(10000);
// Step 8. start the connection ready to receive messages // Step 8. start the connection ready to receive messages
connection.start(); connection.start();

4
examples/jms/colocated-failover/src/main/resources/activemq/server0/broker.xml
View File

@ -89,7 +89,9 @@ under the License.
<master> <master>
<failover-on-shutdown>true</failover-on-shutdown> <failover-on-shutdown>true</failover-on-shutdown>
</master> </master>
<slave/> <slave>
<failover-on-shutdown>true</failover-on-shutdown>
</slave>
</colocated> </colocated>
</shared-store> </shared-store>
</ha-policy> </ha-policy>

8
examples/jms/colocated-failover/src/main/resources/activemq/server1/broker.xml
View File

@ -86,8 +86,12 @@ under the License.
<backup-request-retry-interval>2000</backup-request-retry-interval> <backup-request-retry-interval>2000</backup-request-retry-interval>
<max-backups>1</max-backups> <max-backups>1</max-backups>
<request-backup>true</request-backup> <request-backup>true</request-backup>
<master/> <master>
<slave/> <failover-on-shutdown>true</failover-on-shutdown>
</master>
<slave>
<failover-on-shutdown>true</failover-on-shutdown>
</slave>
</colocated> </colocated>
</shared-store> </shared-store>
</ha-policy> </ha-policy>