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)
{
Show replies by date