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

Friday, 1 July 2011


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()
       {


    