From 3e20906a49974b97e374e01b2099b5fad9cbd8ed Mon Sep 17 00:00:00 2001 From: yang wei Date: Wed, 29 May 2019 16:57:40 +0800 Subject: [PATCH] NO-JIRA typo on logger --- .../activemq/artemis/core/replication/ReplicationManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java index 1d1217d616..6554cc8446 100644 --- a/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java +++ b/artemis-server/src/main/java/org/apache/activemq/artemis/core/replication/ReplicationManager.java @@ -612,7 +612,7 @@ public final class ReplicationManager implements ActiveMQComponent { private void flushReplicationStream(FlushAction action) throws Exception { action.reset(); replicationStream.execute(action); - if (!action.await(this.timeout, TimeUnit.MILLISECONDS)) { + if (!action.await(this.initialReplicationSyncTimeout, TimeUnit.MILLISECONDS)) { throw ActiveMQMessageBundle.BUNDLE.replicationSynchronizationTimeout(initialReplicationSyncTimeout); } }