[hornetq-commits] JBoss hornetq SVN: r8512 - trunk/src/main/org/hornetq/core/replication/impl.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-12-03 02:01:31 -0500 (Thu, 03 Dec 2009)
New Revision: 8512

Modified:
   trunk/src/main/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
   trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
Adding confirmation call on the ReplicationManager

Modified: trunk/src/main/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java	2009-12-02 23:51:36 UTC (rev 8511)
+++ trunk/src/main/org/hornetq/core/replication/impl/ReplicationEndpointImpl.java	2009-12-03 07:01:31 UTC (rev 8512)
@@ -172,6 +172,9 @@
          log.warn(e.getMessage(), e);
          response = new HornetQExceptionMessage((HornetQException)e);
       }
+      
+      channel.confirm(packet);
+      
       channel.send(response);
    }
 

Modified: trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-12-02 23:51:36 UTC (rev 8511)
+++ trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-12-03 07:01:31 UTC (rev 8512)
@@ -491,6 +491,8 @@
          {
             replicated();
          }
+         
+         replicatingChannel.confirm(packet);
       }
 
    }