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 af1e331a10..4951d1399f 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 @@ -262,6 +262,7 @@ class AmqpProtocolConverter implements IAmqpProtocolConverter { break; case LINK_REMOTE_OPEN: case LINK_REMOTE_CLOSE: + case LINK_REMOTE_DETACH: processLinkEvent(event.getLink()); break; case LINK_FLOW: