Apache
/
activemq
mirror of https://github.com/apache/activemq.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

fix the test builds.

This commit is contained in:
Timothy Bish 2014-08-13 09:37:18 -04:00
parent 59f8cfc604
commit eaed01992e
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
activemq-mqtt/src/main/java/org/apache/activemq/transport/mqtt/MQTTProtocolConverter.java
View File

@ -86,6 +86,8 @@ public class MQTTProtocolConverter {
private static final Logger LOG = LoggerFactory.getLogger(MQTTProtocolConverter.class); 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 IdGenerator CONNECTION_ID_GENERATOR = new IdGenerator();
private static final MQTTFrame PING_RESP_FRAME = new PINGRESP().encode(); private static final MQTTFrame PING_RESP_FRAME = new PINGRESP().encode();
private static final double MQTT_KEEP_ALIVE_GRACE_PERIOD = 0.5; private static final double MQTT_KEEP_ALIVE_GRACE_PERIOD = 0.5;
@ -114,7 +116,6 @@ public class MQTTProtocolConverter {
private String clientId; private String clientId;
private long defaultKeepAlive; private long defaultKeepAlive;
private int activeMQSubscriptionPrefetch = 1; private int activeMQSubscriptionPrefetch = 1;
private static final String QOS_PROPERTY_NAME = "ActiveMQ.MQTT.QoS";
private final MQTTPacketIdGenerator packetIdGenerator; private final MQTTPacketIdGenerator packetIdGenerator;
private boolean publishDollarTopics; private boolean publishDollarTopics;