[1/2] activemq-artemis git commit: ARTEMIS-1050 Register AMQP failure/close listeners

Previous Topic Next Topic
 
classic Classic list List threaded Threaded
2 messages Options
Reply | Threaded
Open this post in threaded view
|

[1/2] activemq-artemis git commit: ARTEMIS-1050 Register AMQP failure/close listeners

clebertsuconic-2
Repository: activemq-artemis
Updated Branches:
  refs/heads/master d9a7b2feb -> e29c46373


ARTEMIS-1050 Register AMQP failure/close listeners


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

Branch: refs/heads/master
Commit: 7cf06cd28507c3e0db628d1fa4d8ec25eca1f8b9
Parents: d9a7b2f
Author: Martyn Taylor <[hidden email]>
Authored: Sun Mar 19 14:09:07 2017 +0000
Committer: Martyn Taylor <[hidden email]>
Committed: Sun Mar 19 14:15:30 2017 +0000

----------------------------------------------------------------------
 .../artemis/protocol/amqp/broker/ProtonProtocolManager.java        | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/7cf06cd2/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ProtonProtocolManager.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ProtonProtocolManager.java b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ProtonProtocolManager.java
index 9c7d24d..2828cc1 100644
--- a/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ProtonProtocolManager.java
+++ b/artemis-protocols/artemis-amqp-protocol/src/main/java/org/apache/activemq/artemis/protocol/amqp/broker/ProtonProtocolManager.java
@@ -110,6 +110,8 @@ public class ProtonProtocolManager implements ProtocolManager<Interceptor>, Noti
       Executor executor = server.getExecutorFactory().getExecutor();
 
       ActiveMQProtonRemotingConnection delegate = new ActiveMQProtonRemotingConnection(this, amqpConnection, remotingConnection, executor);
+      delegate.addFailureListener(connectionCallback);
+      delegate.addCloseListener(connectionCallback);
 
       connectionCallback.setProtonConnectionDelegate(delegate);
 

Reply | Threaded
Open this post in threaded view
|

[2/2] activemq-artemis git commit: This closes #1105

clebertsuconic-2
This closes #1105


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

Branch: refs/heads/master
Commit: e29c463732ab27215a3b376eca8642b77751557d
Parents: d9a7b2f 7cf06cd
Author: Clebert Suconic <[hidden email]>
Authored: Mon Mar 20 09:27:47 2017 -0400
Committer: Clebert Suconic <[hidden email]>
Committed: Mon Mar 20 09:27:47 2017 -0400

----------------------------------------------------------------------
 .../artemis/protocol/amqp/broker/ProtonProtocolManager.java        | 2 ++
 1 file changed, 2 insertions(+)
----------------------------------------------------------------------