From 0dcad8fc597510f444fe2df380e7e82de5f35197 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ville=20Skytt=C3=A4?= <ville.skytta@iki.fi>
Date: Mon, 20 Jul 2015 21:29:41 +0300
Subject: [PATCH] Fix MQTT build

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

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 b7fa43624f..468d43a94a 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;