Add management filter to Queue not Consumer MQTT
Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/69294e83 Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/69294e83 Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/69294e83 Branch: refs/heads/master Commit: 69294e83e1f703545d236bde5238e0187a87816c Parents: 6cb6815 Author: Martyn Taylor <mtay...@redhat.com> Authored: Tue Jul 26 11:24:16 2016 +0100 Committer: Andy Taylor <andy.tayl...@gmail.com> Committed: Tue Jul 26 12:32:38 2016 +0100 ---------------------------------------------------------------------- .../artemis/core/protocol/mqtt/MQTTSubscriptionManager.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/69294e83/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSubscriptionManager.java ---------------------------------------------------------------------- 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 cbe64a6..847973b 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);
