From 3338ae2edded376258e16ad601a8a3ecbea755d0 Mon Sep 17 00:00:00 2001
From: Helge Waastad <helge.waastad@gmail.com>
Date: Tue, 20 Jun 2017 14:41:23 +0200
Subject: [PATCH] try to release if message is ReferenceCounted

---
 .../artemis/core/protocol/mqtt/MQTTProtocolHandler.java        | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
index 4a5d12f9e1f..92ca251d1aa 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTProtocolHandler.java
@@ -39,6 +39,7 @@
 import io.netty.handler.codec.mqtt.MqttSubscribeMessage;
 import io.netty.handler.codec.mqtt.MqttUnsubAckMessage;
 import io.netty.handler.codec.mqtt.MqttUnsubscribeMessage;
+import io.netty.util.ReferenceCountUtil;
 import org.apache.activemq.artemis.api.core.RoutingType;
 import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.core.server.ActiveMQServer;
@@ -155,6 +156,8 @@ public void channelRead(ChannelHandlerContext ctx, Object msg) {
       } catch (Exception e) {
          log.debug("Error processing Control Packet, Disconnecting Client", e);
          disconnect(true);
+      } finally {
+          ReferenceCountUtil.release(msg);
       }
    }