Author: ataylor Date: 2011-02-15 05:51:24 -0500 (Tue, 15 Feb 2011) New Revision: 10206 Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java Log: fixed example Modified: branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java =================================================================== --- branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java 2011-02-15 01:04:21 UTC (rev 10205) +++ branches/Branch_2_2_EAP/examples/jms/clustered-static-oneway/src/org/hornetq/jms/example/ClusterStaticOnewayExample.java 2011-02-15 10:51:24 UTC (rev 10206) @@ -16,6 +16,7 @@ import javax.jms.*; import javax.naming.InitialContext; +import java.lang.Exception; /** * A simple example that demonstrates server side load-balancing of messages between the queue instances on different @@ -56,62 +57,51 @@ // Step 3. Look-up a JMS Connection Factory object from JNDI on server 0 ConnectionFactory cf0 = (ConnectionFactory)ic0.lookup("/ConnectionFactory"); - //grab an initial connection and wait, in reality you wouldn't do it this way but since we want to ensure an + //step 4. grab an initial connection and wait, in reality you wouldn't do it this way but since we want to ensure an // equal load balance we do this and then create 4 connections round robined initialConnection = cf0.createConnection(); Thread.sleep(2000); - // Step 6. We create a JMS Connection connection0 which is a connection to server 0 + // Step 5. We create a JMS Connection connection0 which is a connection to server 0 connection0 = cf0.createConnection(); - // Step 7. We create a JMS Connection connection1 which is a connection to server 1 + // Step 6. We create a JMS Connection connection1 which is a connection to server 1 connection1 = cf0.createConnection(); - // Step 6. We create a JMS Connection connection0 which is a connection to server 0 + // Step 7. We create a JMS Connection connection0 which is a connection to server 2 connection2 = cf0.createConnection(); - // Step 7. We create a JMS Connection connection1 which is a connection to server 1 - connection3 = cf0.createConnection(); - // Step 8. We create a JMS Session on server 0 Session session0 = connection0.createSession(false, Session.AUTO_ACKNOWLEDGE); // Step 9. We create a JMS Session on server 1 Session session1 = connection1.createSession(false, Session.AUTO_ACKNOWLEDGE); - - // Step 8. We create a JMS Session on server 0 + // Step 10. We create a JMS Session on server 2 Session session2 = connection2.createSession(false, Session.AUTO_ACKNOWLEDGE); - // Step 9. We create a JMS Session on server 1 - Session session3 = connection3.createSession(false, Session.AUTO_ACKNOWLEDGE); - - // Step 10. We start the connections to ensure delivery occurs on them + // Step 11. We start the connections to ensure delivery occurs on them connection0.start(); connection1.start(); connection2.start(); - connection3.start(); - - // Step 11. We create JMS MessageConsumer objects on server 0 and server 1 + // Step 12. We create JMS MessageConsumer objects on server 0,server 1 and server 2 MessageConsumer consumer0 = session0.createConsumer(queue); MessageConsumer consumer1 = session1.createConsumer(queue); MessageConsumer consumer2 = session2.createConsumer(queue); - MessageConsumer consumer3 = session3.createConsumer(queue); - Thread.sleep(2000); - // Step 12. We create a JMS MessageProducer object on server 3 - MessageProducer producer = session3.createProducer(queue); + // Step 13. We create a JMS MessageProducer object on server 2 + MessageProducer producer = session2.createProducer(queue); - // Step 13. We send some messages to server 0 + // Step 14. We send some messages to server 2 - final int numMessages = 20; + final int numMessages = 18; for (int i = 0; i < numMessages; i++) { @@ -122,20 +112,23 @@ System.out.println("Sent message: " + message.getText()); } Thread.sleep(2000); - // Step 14. We now consume those messages on *both* server 0 and server 1. + // Step 15. We now consume those messages on *both* server 0,server 1 and 3. // We note the messages have been distributed between servers in a round robin fashion // JMS Queues implement point-to-point message where each message is only ever consumed by a // maximum of one consumer int con0Node = getServer(connection0); int con1Node = getServer(connection1); int con2Node = getServer(connection2); - int con3Node = getServer(connection3); - if(con0Node + con1Node + con2Node + con3Node != 6) + if(con0Node + con1Node + con2Node != 3) { + System.out.println("connections not load balanced"); + System.out.println("con0Node = " + con0Node); + System.out.println("con1Node = " + con1Node); + System.out.println("con2Node = " + con2Node); return false; } - for (int i = 0; i < numMessages; i += 4) + for (int i = 0; i < numMessages; i += 3) { TextMessage message0 = (TextMessage)consumer0.receive(5000); @@ -148,10 +141,6 @@ TextMessage message2 = (TextMessage)consumer2.receive(5000); System.out.println("Got message: " + message2.getText() + " from node " + con2Node); - - TextMessage message3 = (TextMessage)consumer3.receive(5000); - - System.out.println("Got message: " + message3.getText() + " from node " + con3Node); } return true;