diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java index 18cb960566..038b22292c 100644 --- a/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/ft/MasterConnector.java @@ -140,7 +140,7 @@ public class MasterConnector implements Service, BrokerServiceAware { } public void onException(IOException error) { - if (started.get() && remoteBroker.isDisposed()) { + if (started.get()) { serviceRemoteException(error); } }