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 <[email protected]> Authored: Wed Aug 13 09:37:18 2014 -0400 Committer: Timothy Bish <[email protected]> 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;
