From 7cf06cd28507c3e0db628d1fa4d8ec25eca1f8b9 Mon Sep 17 00:00:00 2001
From: Martyn Taylor <mtaylor@redhat.com>
Date: Sun, 19 Mar 2017 14:09:07 +0000
Subject: [PATCH] ARTEMIS-1050 Register AMQP failure/close listeners

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

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 9c7d24d10e..2828cc18f8 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);