From 69f82632675c9b4a1327cf70ce53440358b6dc3e Mon Sep 17 00:00:00 2001 From: Martyn Taylor Date: Wed, 12 Jul 2017 12:29:48 +0100 Subject: [PATCH] ARTEMIS-1303 Fix interleave during replication sync --- .../activemq/artemis/core/replication/ReplicationEndpoint.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java index fed4805bcd..4d8161316f 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationEndpoint.java @@ -337,7 +337,7 @@ public final class ReplicationEndpoint implements ChannelHandler, ActiveMQCompon this.channel = channel; } - private void finishSynchronization(String liveID) throws Exception { + private synchronized void finishSynchronization(String liveID) throws Exception { if (logger.isTraceEnabled()) { logger.trace("BACKUP-SYNC-START: finishSynchronization::" + liveID); }