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

This closes #88 Fix jdk 1.7 build on MQTT

This commit is contained in:
Clebert Suconic 2015-07-21 22:18:49 +01:00
parent 9b356bd5c1 0dcad8fc59
commit 5a57bf6f29
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
View File

@ -39,7 +39,7 @@ public class MQTTSessionState
// Used to store Packet ID of Publish QoS1 and QoS2 message. See spec: 4.3.3 QoS 2: Exactly once delivery. Method B.
private Map<Integer, MQTTMessageInfo> messageRefStore;
private Map<String, Map<Long, Integer>> addressMessageMap;
private ConcurrentHashMap<String, Map<Long, Integer>> addressMessageMap;
private Set<Integer> pubRec;