activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From andytay...@apache.org
Subject [2/2] activemq-artemis git commit: Add management filter to Queue not Consumer MQTT
Date Tue, 26 Jul 2016 11:32:52 GMT
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 <mtaylor@redhat.com>
Authored: Tue Jul 26 11:24:16 2016 +0100
Committer: Andy Taylor <andy.tayls67@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);


Mime
View raw message