You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by ta...@apache.org on 2014/08/13 15:37:31 UTC
git commit: fix the test builds.
Repository: activemq
Updated Branches:
refs/heads/trunk 59f8cfc60 -> eaed01992
fix the test builds.
Project: http://git-wip-us.apache.org/repos/asf/activemq/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq/commit/eaed0199
Tree: http://git-wip-us.apache.org/repos/asf/activemq/tree/eaed0199
Diff: http://git-wip-us.apache.org/repos/asf/activemq/diff/eaed0199
Branch: refs/heads/trunk
Commit: eaed01992efcea43fde36142d55a02a894afd439
Parents: 59f8cfc
Author: Timothy Bish <ta...@gmail.com>
Authored: Wed Aug 13 09:37:18 2014 -0400
Committer: Timothy Bish <ta...@gmail.com>
Committed: Wed Aug 13 09:37:18 2014 -0400
----------------------------------------------------------------------
.../org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java | 3 ++-
1 file changed, 2 insertions(+), 1 deletion(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/activemq/blob/eaed0199/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
----------------------------------------------------------------------
diff --git a/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java b/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
index b4d21ce..d80b10a 100644
--- a/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
+++ b/activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
@@ -86,6 +86,8 @@ public class MQTTProtocolConverter {
private static final Logger LOG = LoggerFactory.getLogger(MQTTProtocolConverter.class);
+ public static final String QOS_PROPERTY_NAME = "ActiveMQ.MQTT.QoS";
+
private static final IdGenerator CONNECTION_ID_GENERATOR = new IdGenerator();
private static final MQTTFrame PING_RESP_FRAME = new PINGRESP().encode();
private static final double MQTT_KEEP_ALIVE_GRACE_PERIOD = 0.5;
@@ -114,7 +116,6 @@ public class MQTTProtocolConverter {
private String clientId;
private long defaultKeepAlive;
private int activeMQSubscriptionPrefetch = 1;
- private static final String QOS_PROPERTY_NAME = "ActiveMQ.MQTT.QoS";
private final MQTTPacketIdGenerator packetIdGenerator;
private boolean publishDollarTopics;