diff --git a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/ChannelBroadcastEndpointFactory.java b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/ChannelBroadcastEndpointFactory.java index 5be1d6dca5..58075bf2a1 100644 --- a/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/ChannelBroadcastEndpointFactory.java +++ b/artemis-core-client/src/main/java/org/apache/activemq/artemis/api/core/ChannelBroadcastEndpointFactory.java @@ -30,6 +30,16 @@ public class ChannelBroadcastEndpointFactory implements BroadcastEndpointFactory this.channelName = channelName; } + public JChannel getChannel() + { + return channel; + } + + public String getChannelName() + { + return channelName; + } + @Override public BroadcastEndpoint createBroadcastEndpoint() throws Exception {