diff --git a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java index f98dc00011..cfb3dd61aa 100755 --- a/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java +++ b/activemq-core/src/main/java/org/apache/activemq/broker/TransportConnection.java @@ -992,7 +992,7 @@ public class TransportConnection implements Service,Connection,Task,CommandVisit ProducerState producerState=ss.getProducerState(id); if(producerState!=null&&producerState.getInfo()!=null){ ProducerInfo info=producerState.getInfo(); - result.setMutable(info.getDestination()==null); + result.setMutable(info.getDestination()==null||info.getDestination().isComposite()); } } producerExchanges.put(id,result);