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

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) {