[jboss-cvs] JBoss Messaging SVN: r1835 - trunk/docs/examples/queue-failover/src/org/jboss/example/jms/failover

[jboss-cvs-commits at lists.jboss.org]

Author: timfox
Date: 2006-12-20 06:01:42 -0500 (Wed, 20 Dec 2006)
New Revision: 1835

Modified:
   trunk/docs/examples/queue-failover/src/org/jboss/example/jms/failover/QueueFailoverExample.java
Log:
Fixed test



Modified: trunk/docs/examples/queue-failover/src/org/jboss/example/jms/failover/QueueFailoverExample.java
===================================================================
--- trunk/docs/examples/queue-failover/src/org/jboss/example/jms/failover/QueueFailoverExample.java	2006-12-20 10:58:07 UTC (rev 1834)
+++ trunk/docs/examples/queue-failover/src/org/jboss/example/jms/failover/QueueFailoverExample.java	2006-12-20 11:01:42 UTC (rev 1835)
@@ -54,19 +54,19 @@
 
       String destinationName = getDestinationJNDIName();
 
-
       InitialContext ic = null;
 
-
       Connection connection = null;
 
       try
       {
          // Create a connection to the clustered messaging instance
 
+
          ic = new InitialContext();
 
          ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
+
          Queue distributedQueue = (Queue)ic.lookup(destinationName);
          log("Distributed queue " + destinationName + " exists");
 
@@ -87,7 +87,9 @@
 
          producer.send(message);
 
+         MessageConsumer consumer = session.createConsumer(distributedQueue);
 
+
          log("The message was successfully sent to the distributed queue");
 
 
@@ -99,10 +101,8 @@
          Thread.sleep(30000); // TODO not necesare after we install the client valve
 
 
-         // Transparenty create a consumer and receive the message
+         // receive the message
 
-         MessageConsumer consumer = session.createConsumer(distributedQueue);
-
          message = (TextMessage)consumer.receive(2000);
          log("Received message: " + message.getText());
          assertEquals("Hello!", message.getText());