You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2011/09/11 23:41:50 UTC
svn commit: r1169549 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
Author: tabish
Date: Sun Sep 11 21:41:49 2011
New Revision: 1169549
URL: http://svn.apache.org/viewvc?rev=1169549&view=rev
Log:
fix for: https://issues.apache.org/jira/browse/AMQ-3488
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java?rev=1169549&r1=1169548&r2=1169549&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/AdvisoryConsumer.java Sun Sep 11 21:41:49 2011
@@ -96,7 +96,9 @@ public class AdvisoryConsumer implements
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);