diff --git a/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java b/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java index b1d20ad09c..11060ecca0 100755 --- a/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java +++ b/activemq-optional/src/main/java/org/apache/activemq/transport/http/BlockingQueueTransport.java @@ -57,7 +57,7 @@ public class BlockingQueueTransport extends TransportSupport { public String getRemoteAddress() { - return "blockingQueue"; + return "blockingQueue_" + queue.hashCode(); } protected void doStart() throws Exception {