Apache
/
activemq-artemis
mirror of https://github.com/apache/activemq-artemis.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

ARTEMIS-350 Small improvement on the replication stop

This commit is contained in:
Clebert Suconic 2016-01-19 11:14:16 -05:00
parent b7f0d14b18
commit 68faa1d252
1 changed files with 9 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java
View File

@ -263,14 +263,17 @@ public final class ReplicationManager implements ActiveMQComponent, ReadyListene
if (!started) { if (!started) {
return; return;
} }
replicatingChannel.getConnection().getTransportConnection().fireReady(true);
latch.setCount(0);
synchronized (replicationLock) {
enabled = false; enabled = false;
// This is to avoid the write holding a lock while we are trying to close it
if (replicatingChannel != null) { if (replicatingChannel != null) {
replicatingChannel.close(); replicatingChannel.close();
replicatingChannel.getConnection().getTransportConnection().fireReady(true);
latch.setCount(0);
} }
synchronized (replicationLock) {
clearReplicationTokens(); clearReplicationTokens();
} }
@ -278,7 +281,6 @@ public final class ReplicationManager implements ActiveMQComponent, ReadyListene
if (toStop != null) { if (toStop != null) {
toStop.removeFailureListener(failureListener); toStop.removeFailureListener(failureListener);
} }
remotingConnection = null; remotingConnection = null;
started = false; started = false;
} }