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

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-12-03 10:30:02 -0500 (Thu, 03 Dec 2009)
New Revision: 8528

Modified:
   trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
reverted r8527

Modified: trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
===================================================================
--- trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-12-03 15:15:26 UTC (rev 8527)
+++ trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-12-03 15:30:02 UTC (rev 8528)
@@ -374,6 +374,21 @@
       }
       
       enabled = false;
+      
+      // The same context will be replicated on the pending tokens...
+      // as the multiple operations will be replicated on the same context
+      while (!pendingTokens.isEmpty())
+      {
+         OperationContext ctx = pendingTokens.poll();
+         try
+         {
+            ctx.replicationDone();
+         }
+         catch (Throwable e)
+         {
+            log.warn("Error completing callback on replication manager", e);
+         }
+      }
 
       if (replicatingChannel != null)
       {