From 0d08a5a20fea55838ef5a834810868d9f98e55fd Mon Sep 17 00:00:00 2001 From: "Timothy A. Bish" Date: Sun, 11 Sep 2011 21:41:49 +0000 Subject: [PATCH] fix for: https://issues.apache.org/jira/browse/AMQ-3488 git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1169549 13f79535-47bb-0310-9956-ffa450edef68 --- .../src/main/java/org/apache/activemq/AdvisoryConsumer.java | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java b/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java index 475af7ba00..b2c02c8326 100755 --- a/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java +++ b/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java @@ -96,7 +96,9 @@ public class AdvisoryConsumer implements ActiveMQDispatcher { ActiveMQTempDestination tempDest = (ActiveMQTempDestination)dest; if (dinfo.getOperationType() == DestinationInfo.ADD_OPERATION_TYPE) { - tempDest.setConnection(null); + if (tempDest.getConnection() != null) { + tempDest = (ActiveMQTempDestination) tempDest.createDestination(tempDest.getPhysicalName()); + } connection.activeTempDestinations.put(tempDest, tempDest); } else if (dinfo.getOperationType() == DestinationInfo.REMOVE_OPERATION_TYPE) { connection.activeTempDestinations.remove(tempDest);