From 0b577d8ebd8c7a35ad4c84ed1bc048f21bb2d9d6 Mon Sep 17 00:00:00 2001 From: Robert Godfrey Date: Mon, 18 Aug 2014 18:13:09 +0000 Subject: QPID-6014 : [Java] declare variables as ConcurrentMap not ConcurrentHashMap to avoid linking issues after compiling under Java 8 git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1618690 13f79535-47bb-0310-9956-ffa450edef68 --- .../qpid/amqp_1_0/codec/SymbolTypeConstructor.java | 11 ++++++----- .../java/org/apache/qpid/amqp_1_0/type/Symbol.java | 3 ++- .../store/berkeleydb/StandardEnvironmentFacade.java | 18 +++++++++--------- .../replication/ReplicatedEnvironmentFacade.java | 4 ++-- .../java/org/apache/qpid/server/BrokerOptions.java | 3 ++- .../apache/qpid/server/exchange/AbstractExchange.java | 3 ++- .../apache/qpid/server/exchange/DirectExchange.java | 3 ++- .../apache/qpid/server/exchange/HeadersExchange.java | 3 ++- .../server/exchange/topic/TopicExchangeResult.java | 13 +++++++------ .../server/exchange/topic/TopicWordDictionary.java | 3 ++- .../queue/AssignedConsumerMessageGroupManager.java | 9 +++++---- .../apache/qpid/server/queue/LastValueQueueList.java | 3 ++- .../apache/qpid/server/security/SecurityManager.java | 5 +++-- .../apache/qpid/server/store/AbstractMemoryStore.java | 3 ++- .../apache/qpid/server/store/MemoryMessageStore.java | 3 ++- .../qpid/server/queue/StandardQueueEntryListTest.java | 3 ++- .../qpid/server/protocol/v1_0/SendingLink_1_0.java | 3 ++- .../main/java/org/apache/qpid/client/AMQSession.java | 9 +++++---- .../java/org/apache/qpid/framing/AMQShortString.java | 11 ++++++----- 19 files changed, 65 insertions(+), 48 deletions(-) (limited to 'qpid/java') diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/SymbolTypeConstructor.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/SymbolTypeConstructor.java index b96e1ab47b..b75bba8c6a 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/SymbolTypeConstructor.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/codec/SymbolTypeConstructor.java @@ -20,19 +20,20 @@ */ package org.apache.qpid.amqp_1_0.codec; -import org.apache.qpid.amqp_1_0.type.AmqpErrorException; -import org.apache.qpid.amqp_1_0.type.Symbol; - import java.nio.ByteBuffer; import java.nio.CharBuffer; import java.nio.charset.Charset; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; + +import org.apache.qpid.amqp_1_0.type.AmqpErrorException; +import org.apache.qpid.amqp_1_0.type.Symbol; public class SymbolTypeConstructor extends VariableWidthTypeConstructor { private static final Charset ASCII = Charset.forName("US-ASCII"); - private static final ConcurrentHashMap SYMBOL_MAP = + private static final ConcurrentMap SYMBOL_MAP = new ConcurrentHashMap(2048); public static SymbolTypeConstructor getInstance(int i) @@ -89,4 +90,4 @@ public class SymbolTypeConstructor extends VariableWidthTypeConstructor } -} \ No newline at end of file +} diff --git a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/Symbol.java b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/Symbol.java index de4e86f201..93be3ee873 100644 --- a/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/Symbol.java +++ b/qpid/java/amqp-1-0-common/src/main/java/org/apache/qpid/amqp_1_0/type/Symbol.java @@ -22,11 +22,12 @@ package org.apache.qpid.amqp_1_0.type; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; public final class Symbol implements Comparable, CharSequence { private final String _underlying; - private static final ConcurrentHashMap _symbols = new ConcurrentHashMap(2048); + private static final ConcurrentMap _symbols = new ConcurrentHashMap(2048); private Symbol(String underlying) { diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/StandardEnvironmentFacade.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/StandardEnvironmentFacade.java index 6451bc6927..a3b3ec7324 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/StandardEnvironmentFacade.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/StandardEnvironmentFacade.java @@ -24,28 +24,28 @@ import java.io.File; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; - -import com.sleepycat.je.DatabaseEntry; -import com.sleepycat.je.Sequence; -import com.sleepycat.je.SequenceConfig; - -import org.apache.log4j.Logger; -import org.apache.qpid.server.store.StoreFuture; +import java.util.concurrent.ConcurrentMap; import com.sleepycat.je.Database; import com.sleepycat.je.DatabaseConfig; +import com.sleepycat.je.DatabaseEntry; import com.sleepycat.je.DatabaseException; import com.sleepycat.je.Environment; import com.sleepycat.je.EnvironmentConfig; +import com.sleepycat.je.Sequence; +import com.sleepycat.je.SequenceConfig; import com.sleepycat.je.Transaction; +import org.apache.log4j.Logger; + +import org.apache.qpid.server.store.StoreFuture; public class StandardEnvironmentFacade implements EnvironmentFacade { private static final Logger LOGGER = Logger.getLogger(StandardEnvironmentFacade.class); private final String _storePath; - private final ConcurrentHashMap _cachedDatabases = new ConcurrentHashMap<>(); - private final ConcurrentHashMap _cachedSequences = new ConcurrentHashMap<>(); + private final ConcurrentMap _cachedDatabases = new ConcurrentHashMap<>(); + private final ConcurrentMap _cachedSequences = new ConcurrentHashMap<>(); private Environment _environment; private final Committer _committer; diff --git a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java index d045ae01fa..4f47e0fa53 100644 --- a/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java +++ b/qpid/java/bdbstore/src/main/java/org/apache/qpid/server/store/berkeleydb/replication/ReplicatedEnvironmentFacade.java @@ -170,8 +170,8 @@ public class ReplicatedEnvironmentFacade implements EnvironmentFacade, StateChan private volatile ReplicatedEnvironment.State _lastKnownEnvironmentState; private volatile Durability _messageStoreDurability; - private final ConcurrentHashMap _cachedDatabases = new ConcurrentHashMap<>(); - private final ConcurrentHashMap _cachedSequences = new ConcurrentHashMap<>(); + private final ConcurrentMap _cachedDatabases = new ConcurrentHashMap<>(); + private final ConcurrentMap _cachedSequences = new ConcurrentHashMap<>(); private final Set _permittedNodes = new CopyOnWriteArraySet(); public ReplicatedEnvironmentFacade(ReplicatedEnvironmentConfiguration configuration) diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java index 418e5c2657..a6fae97aaa 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/BrokerOptions.java @@ -25,6 +25,7 @@ import java.util.Collections; import java.util.HashMap; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import org.apache.qpid.server.configuration.BrokerProperties; import org.apache.qpid.server.model.ConfiguredObject; @@ -306,7 +307,7 @@ public class BrokerOptions */ public Map getConfigProperties() { - ConcurrentHashMap properties = new ConcurrentHashMap(); + ConcurrentMap properties = new ConcurrentHashMap(); properties.putAll(_configProperties); properties.putIfAbsent(QPID_WORK_DIR, getWorkDir()); diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java index e41bb948dc..4472669f4a 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/AbstractExchange.java @@ -30,6 +30,7 @@ import java.util.Map; import java.util.Set; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.atomic.AtomicBoolean; import java.util.concurrent.atomic.AtomicInteger; @@ -102,7 +103,7 @@ public abstract class AbstractExchange> private final CopyOnWriteArrayList _listeners = new CopyOnWriteArrayList(); - private final ConcurrentHashMap _bindingsMap = new ConcurrentHashMap(); + private final ConcurrentMap _bindingsMap = new ConcurrentHashMap(); private StateChangeListener _bindingListener; private State _state = State.UNINITIALIZED; diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java index 4997095315..66de22ece8 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/DirectExchange.java @@ -28,6 +28,7 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArraySet; import org.apache.log4j.Logger; @@ -133,7 +134,7 @@ public class DirectExchange extends AbstractExchange } } - private final ConcurrentHashMap _bindingsByKey = + private final ConcurrentMap _bindingsByKey = new ConcurrentHashMap(); @ManagedObjectFactoryConstructor diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java index 83c6b9fd00..67bbc26f74 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/HeadersExchange.java @@ -25,6 +25,7 @@ import java.util.LinkedHashSet; import java.util.ListIterator; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CopyOnWriteArraySet; @@ -74,7 +75,7 @@ public class HeadersExchange extends AbstractExchange private static final Logger _logger = Logger.getLogger(HeadersExchange.class); - private final ConcurrentHashMap> _bindingsByKey = + private final ConcurrentMap> _bindingsByKey = new ConcurrentHashMap>(); private final CopyOnWriteArrayList _bindingHeaderMatchers = diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicExchangeResult.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicExchangeResult.java index d3a6bd9260..0db3e9b378 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicExchangeResult.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicExchangeResult.java @@ -20,11 +20,6 @@ */ package org.apache.qpid.server.exchange.topic; -import org.apache.qpid.server.binding.BindingImpl; -import org.apache.qpid.server.filter.Filterable; -import org.apache.qpid.server.filter.MessageFilter; -import org.apache.qpid.server.queue.AMQQueue; - import java.util.ArrayList; import java.util.Collection; import java.util.HashSet; @@ -32,13 +27,19 @@ import java.util.List; import java.util.Map; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; +import org.apache.qpid.server.binding.BindingImpl; +import org.apache.qpid.server.filter.Filterable; +import org.apache.qpid.server.filter.MessageFilter; +import org.apache.qpid.server.queue.AMQQueue; + public final class TopicExchangeResult implements TopicMatcherResult { private final List _bindings = new CopyOnWriteArrayList(); private final Map _unfilteredQueues = new ConcurrentHashMap(); - private final ConcurrentHashMap> _filteredQueues = new ConcurrentHashMap>(); + private final ConcurrentMap> _filteredQueues = new ConcurrentHashMap>(); private volatile ArrayList _unfilteredQueueList = new ArrayList(0); public void addUnfilteredQueue(AMQQueue queue) diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicWordDictionary.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicWordDictionary.java index 24c41ee7da..181f1d32b7 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicWordDictionary.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/exchange/topic/TopicWordDictionary.java @@ -21,10 +21,11 @@ package org.apache.qpid.server.exchange.topic; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; public class TopicWordDictionary { - private final ConcurrentHashMap _dictionary = + private final ConcurrentMap _dictionary = new ConcurrentHashMap(); public TopicWordDictionary() diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AssignedConsumerMessageGroupManager.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AssignedConsumerMessageGroupManager.java index 8220993e03..e1b25e5abb 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AssignedConsumerMessageGroupManager.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/AssignedConsumerMessageGroupManager.java @@ -20,11 +20,12 @@ */ package org.apache.qpid.server.queue; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.util.Iterator; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; public class AssignedConsumerMessageGroupManager implements MessageGroupManager @@ -33,7 +34,7 @@ public class AssignedConsumerMessageGroupManager implements MessageGroupManager private final String _groupId; - private final ConcurrentHashMap> _groupMap = new ConcurrentHashMap>(); + private final ConcurrentMap> _groupMap = new ConcurrentHashMap>(); private final int _groupMask; public AssignedConsumerMessageGroupManager(final String groupId, final int maxGroups) diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/LastValueQueueList.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/LastValueQueueList.java index 6f1edf12e5..1e250ac2c9 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/LastValueQueueList.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/queue/LastValueQueueList.java @@ -24,6 +24,7 @@ package org.apache.qpid.server.queue; import java.util.Collections; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicReference; import org.slf4j.Logger; @@ -48,7 +49,7 @@ public class LastValueQueueList extends OrderedQueueEntryList }; private final String _conflationKey; - private final ConcurrentHashMap> _latestValuesMap = + private final ConcurrentMap> _latestValuesMap = new ConcurrentHashMap>(); private final ConflationQueueEntry _deleteInProgress = new ConflationQueueEntry(this); diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/SecurityManager.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/SecurityManager.java index 2f7acba91d..96bd9ee0d6 100755 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/SecurityManager.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/security/SecurityManager.java @@ -35,6 +35,7 @@ import java.util.Collection; import java.util.Collections; import java.util.Set; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import javax.security.auth.Subject; @@ -63,11 +64,11 @@ public class SecurityManager implements ConfigurationChangeListener Collections.emptySet(), Collections.emptySet()); - private final ConcurrentHashMap _plugins = new ConcurrentHashMap(); + private final ConcurrentMap _plugins = new ConcurrentHashMap(); private final boolean _managementMode; private final Broker _broker; - private final ConcurrentHashMap _publishAccessCheckCache = new ConcurrentHashMap(); + private final ConcurrentMap _publishAccessCheckCache = new ConcurrentHashMap(); public SecurityManager(Broker broker, boolean managementMode) { diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/AbstractMemoryStore.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/AbstractMemoryStore.java index 4d5cb84d04..a9af138a02 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/AbstractMemoryStore.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/AbstractMemoryStore.java @@ -24,6 +24,7 @@ import java.util.ArrayList; import java.util.List; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import org.apache.qpid.server.model.ConfiguredObject; import org.apache.qpid.server.store.handler.ConfiguredObjectRecordHandler; @@ -34,7 +35,7 @@ public abstract class AbstractMemoryStore implements DurableConfigurationStore, private final Class _rootClass; - private final ConcurrentHashMap _configuredObjectRecords = new ConcurrentHashMap(); + private final ConcurrentMap _configuredObjectRecords = new ConcurrentHashMap(); protected AbstractMemoryStore(final Class rootClass) { diff --git a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java index f3b2cac52e..9c0a5118ff 100644 --- a/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java +++ b/qpid/java/broker-core/src/main/java/org/apache/qpid/server/store/MemoryMessageStore.java @@ -26,6 +26,7 @@ import java.util.Map; import java.util.Set; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.atomic.AtomicLong; import org.apache.qpid.server.message.EnqueueableMessage; @@ -41,7 +42,7 @@ public class MemoryMessageStore implements MessageStore private final AtomicLong _messageId = new AtomicLong(1); - private final ConcurrentHashMap _messages = new ConcurrentHashMap(); + private final ConcurrentMap _messages = new ConcurrentHashMap(); private final Object _transactionLock = new Object(); private final Map> _messageInstances = new HashMap>(); private final Map _distributedTransactions = new HashMap(); diff --git a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueEntryListTest.java b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueEntryListTest.java index 95c53c8428..28d22a5a44 100644 --- a/qpid/java/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueEntryListTest.java +++ b/qpid/java/broker-core/src/test/java/org/apache/qpid/server/queue/StandardQueueEntryListTest.java @@ -28,6 +28,7 @@ import java.util.HashMap; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import org.apache.qpid.server.configuration.updater.CurrentThreadTaskExecutor; import org.apache.qpid.server.logging.EventLogger; @@ -155,7 +156,7 @@ public class StandardQueueEntryListTest extends QueueEntryListTestBase public void testScavenge() throws Exception { OrderedQueueEntryList sqel = new StandardQueueEntryList(null); - ConcurrentHashMap entriesMap = new ConcurrentHashMap(); + ConcurrentMap entriesMap = new ConcurrentHashMap(); //Add messages to generate QueueEntry's diff --git a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java index a8fc5387b4..deaa3ef50b 100644 --- a/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java +++ b/qpid/java/broker-plugins/amqp-1-0-protocol/src/main/java/org/apache/qpid/server/protocol/v1_0/SendingLink_1_0.java @@ -30,6 +30,7 @@ import java.util.List; import java.util.Map; import java.util.UUID; import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; import org.apache.log4j.Logger; @@ -92,7 +93,7 @@ public class SendingLink_1_0 implements SendingLinkListener, Link_1_0, DeliveryS private final Map _unsettledMap = new HashMap(); - private final ConcurrentHashMap _unsettledActionMap = + private final ConcurrentMap _unsettledActionMap = new ConcurrentHashMap(); private volatile SendingLinkAttachment _linkAttachment; private TerminusDurability _durability; diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java index 35252204ac..c2659194e2 100644 --- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java +++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java @@ -31,6 +31,7 @@ import java.util.List; import java.util.Map; import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.concurrent.ConcurrentMap; import java.util.concurrent.CopyOnWriteArrayList; import java.util.concurrent.CountDownLatch; import java.util.concurrent.atomic.AtomicBoolean; @@ -157,10 +158,10 @@ public abstract class AMQSession> _subscriptions = + private final ConcurrentMap> _subscriptions = new ConcurrentHashMap>(); - private final ConcurrentHashMap _reverseSubscriptionMap = new ConcurrentHashMap(); + private final ConcurrentMap _reverseSubscriptionMap = new ConcurrentHashMap(); private final Lock _subscriberDetails = new ReentrantLock(true); private final Lock _subscriberAccess = new ReentrantLock(true); @@ -200,7 +201,7 @@ public abstract class AMQSession _removedConsumers = new CopyOnWriteArrayList(); /** Provides a count of consumers on destinations, in order to be able to know if a destination has consumers. */ - private ConcurrentHashMap _destinationConsumerCount = + private ConcurrentMap _destinationConsumerCount = new ConcurrentHashMap(); /** @@ -312,7 +313,7 @@ public abstract class AMQSession { private final BasicMessageConsumer[] _fastAccessConsumers = new BasicMessageConsumer[16]; - private final ConcurrentHashMap _slowAccessConsumers = new ConcurrentHashMap(); + private final ConcurrentMap _slowAccessConsumers = new ConcurrentHashMap(); public C get(int id) { diff --git a/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java b/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java index a06fa2d15b..17735f5c9c 100644 --- a/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java +++ b/qpid/java/common/src/main/java/org/apache/qpid/framing/AMQShortString.java @@ -21,15 +21,16 @@ package org.apache.qpid.framing; -import java.util.concurrent.ConcurrentHashMap; -import org.slf4j.Logger; -import org.slf4j.LoggerFactory; - import java.io.DataInput; import java.io.DataOutput; import java.io.IOException; import java.util.Arrays; import java.util.Collection; +import java.util.concurrent.ConcurrentHashMap; +import java.util.concurrent.ConcurrentMap; + +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; /** * A short string is a representation of an AMQ Short String @@ -97,7 +98,7 @@ public final class AMQShortString implements CharSequence, Comparable _globalInternMap = + private static final ConcurrentMap _globalInternMap = new ConcurrentHashMap(); private static final Logger _logger = LoggerFactory.getLogger(AMQShortString.class); -- cgit v1.2.1