activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From hadr...@apache.org
Subject [08/23] git commit: https://issues.apache.org/jira/browse/AMQ-4962
Date Fri, 14 Mar 2014 15:07:48 GMT
https://issues.apache.org/jira/browse/AMQ-4962

ensure immediate removal of connection MBean


Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/74deb9ca
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/74deb9ca
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/74deb9ca

Branch: refs/heads/activemq-5.9
Commit: 74deb9cafe4ef58412a5e470d5580f50fe65043e
Parents: 8c8cea8
Author: Timothy Bish <tabish121@gmai.com>
Authored: Mon Jan 6 17:38:41 2014 -0500
Committer: Hadrian Zbarcea <hadrian@apache.org>
Committed: Fri Mar 14 10:54:55 2014 -0400

----------------------------------------------------------------------
 .../org/apache/activemq/transport/amqp/AmqpProtocolConverter.java  | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq/blob/74deb9ca/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
index ed5343c..1c7c0e2 100644
--- a/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
+++ b/activemq-amqp/src/main/java/org/apache/activemq/transport/amqp/AmqpProtocolConverter.java
@@ -50,6 +50,7 @@ import org.apache.activemq.command.RemoveSubscriptionInfo;
 import org.apache.activemq.command.Response;
 import org.apache.activemq.command.SessionId;
 import org.apache.activemq.command.SessionInfo;
+import org.apache.activemq.command.ShutdownInfo;
 import org.apache.activemq.command.TransactionInfo;
 import org.apache.activemq.selector.SelectorParser;
 import org.apache.activemq.util.IOExceptionSupport;
@@ -318,6 +319,7 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter {
                     }
                 }
             });
+            sendToActiveMQ(new ShutdownInfo(), null);
         }
     }
 


Mime
View raw message