[jboss-cvs] JBoss Messaging SVN: r8399 - branches/PATCH_1893_ON_CP07/src/main/org/jboss/messaging/core/impl/clusterconnection.

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

Author: gaohoward
Date: 2011-07-31 23:15:30 -0400 (Sun, 31 Jul 2011)
New Revision: 8399

Modified:
   branches/PATCH_1893_ON_CP07/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
Log:
fix test


Modified: branches/PATCH_1893_ON_CP07/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java
===================================================================
--- branches/PATCH_1893_ON_CP07/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2011-07-31 15:55:12 UTC (rev 8398)
+++ branches/PATCH_1893_ON_CP07/src/main/org/jboss/messaging/core/impl/clusterconnection/MessageSucker.java	2011-08-01 03:15:30 UTC (rev 8399)
@@ -134,15 +134,14 @@
 		clientConsumer = ((ConsumerState)consumer.getState()).getClientConsumer();
 								
 		consumer.setMessageListener(this);		
-		
+      
+      started = true;
 		//Register ourselves with the local queue - this queue will handle flow control for us
 		
 		if (trace) { log.trace(this + " Registering sucker"); }
 		
 		localQueue.registerSucker(this);
 		
-		started = true;
-		
 		if (trace) { log.trace(this + " Registered sucker"); }
 	}