diff --git a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java index b86a785ce9..485e1aa9b8 100755 --- a/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java +++ b/activemq-core/src/main/java/org/apache/activemq/advisory/AdvisoryBroker.java @@ -17,6 +17,7 @@ package org.apache.activemq.advisory; import java.util.Iterator; +import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; @@ -318,4 +319,19 @@ public class AdvisoryBroker extends BrokerFilter { } } + public Map getAdvisoryConnections() { + return connections; + } + + public Map getAdvisoryConsumers() { + return consumers; + } + + public Map getAdvisoryProducers() { + return producers; + } + + public Map getAdvisoryDestinations() { + return destinations; + } }