From 69294e83e1f703545d236bde5238e0187a87816c Mon Sep 17 00:00:00 2001 From: Martyn Taylor Date: Tue, 26 Jul 2016 11:24:16 +0100 Subject: [PATCH] Add management filter to Queue not Consumer MQTT --- .../artemis/core/protocol/mqtt/MQTTSubscriptionManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java index cbe64a6a53..847973bb3f 100644 --- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java +++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java @@ -92,7 +92,7 @@ public class MQTTSubscriptionManager { Queue q = session.getServer().locateQueue(queue); if (q == null) { - session.getServerSession().createQueue(new SimpleString(address), queue, null, false, MQTTUtil.DURABLE_MESSAGES && qos >= 0); + session.getServerSession().createQueue(new SimpleString(address), queue, managementFilter, false, MQTTUtil.DURABLE_MESSAGES && qos >= 0); } return queue; } @@ -102,7 +102,7 @@ public class MQTTSubscriptionManager { */ private void createConsumerForSubscriptionQueue(SimpleString queue, String topic, int qos) throws Exception { long cid = session.getServer().getStorageManager().generateID(); - ServerConsumer consumer = session.getServerSession().createConsumer(cid, queue, managementFilter, false, true, -1); + ServerConsumer consumer = session.getServerSession().createConsumer(cid, queue, null, false, true, -1); consumer.setStarted(true); consumers.put(topic, consumer);