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()
{
Show replies by date