activemq-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From clebertsuco...@apache.org
Subject [2/2] activemq-artemis git commit: Fix MQTT build
Date Tue, 21 Jul 2015 21:19:02 GMT
Fix MQTT build

putIfAbsent() is a ConcurrentHashMap method.


Project: http://git-wip-us.apache.org/repos/asf/activemq-artemis/repo
Commit: http://git-wip-us.apache.org/repos/asf/activemq-artemis/commit/0dcad8fc
Tree: http://git-wip-us.apache.org/repos/asf/activemq-artemis/tree/0dcad8fc
Diff: http://git-wip-us.apache.org/repos/asf/activemq-artemis/diff/0dcad8fc

Branch: refs/heads/master
Commit: 0dcad8fc597510f444fe2df380e7e82de5f35197
Parents: 9b356bd
Author: Ville Skyttä <ville.skytta@iki.fi>
Authored: Mon Jul 20 21:29:41 2015 +0300
Committer: Clebert Suconic <clebertsuconic@apache.org>
Committed: Tue Jul 21 22:18:49 2015 +0100

----------------------------------------------------------------------
 .../activemq/artemis/core/protocol/mqtt/MQTTSessionState.java      | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/activemq-artemis/blob/0dcad8fc/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
----------------------------------------------------------------------
diff --git a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
index b7fa436..468d43a 100644
--- a/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
+++ b/artemis-protocols/artemis-mqtt-protocol/src/main/java/org/apache/activemq/artemis/core/protocol/mqtt/MQTTSessionState.java
@@ -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;
 


Mime
View raw message