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

[do-not-reply at jboss.org]

Author: jmesnil
Date: 2009-12-03 10:15:26 -0500 (Thu, 03 Dec 2009)
New Revision: 8527

Modified:
   trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java
Log:
server shutdown

* do not wait for pending completions when stopping the replication manager

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:13:37 UTC (rev 8526)
+++ trunk/src/main/org/hornetq/core/replication/impl/ReplicationManagerImpl.java	2009-12-03 15:15:26 UTC (rev 8527)
@@ -374,21 +374,6 @@
       }
       
       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)
       {