diff --git a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java index c8bb1386c5f..bddbb6b6c74 100644 --- a/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java +++ b/activemq-broker/src/main/java/org/apache/activemq/network/DemandForwardingBridgeSupport.java @@ -156,7 +156,7 @@ public abstract class DemandForwardingBridgeSupport implements NetworkBridge, Br protected final NetworkBridgeStatistics networkBridgeStatistics = new NetworkBridgeStatistics(); - private NetworkBridgeListener networkBridgeListener; + private volatile NetworkBridgeListener networkBridgeListener; private boolean createdByDuplex; private BrokerInfo localBrokerInfo; private BrokerInfo remoteBrokerInfo;