Author: clebert.suconic(a)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); } }