[hornetq-commits] JBoss hornetq SVN: r10912 - branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl.

[do-not-reply at jboss.org]

Author: borges
Date: 2011-07-01 12:00:44 -0400 (Fri, 01 Jul 2011)
New Revision: 10912

Modified:
   branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
HORNETQ-720 Don't use a blocking send, as the backup node is already up.

Modified: branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
===================================================================
--- branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2011-07-01 16:00:03 UTC (rev 10911)
+++ branches/HORNETQ-720_Replication/hornetq-core/src/main/java/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2011-07-01 16:00:44 UTC (rev 10912)
@@ -316,7 +316,7 @@
 
       Channel systemChannel = remotingConnection.getChannel(CHANNEL_ID.SESSION.id, -1);
 
-      systemChannel.sendBlocking(replicationStartPackage);
+      systemChannel.send(replicationStartPackage);
 
       failureListener = new SessionFailureListener()
       {