diff options
Diffstat (limited to 'qpid/java/amqp-1-0-common/src/main/java/org')
2 files changed, 8 insertions, 6 deletions
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<BinaryString, Symbol> SYMBOL_MAP = + private static final ConcurrentMap<BinaryString, Symbol> SYMBOL_MAP = new ConcurrentHashMap<BinaryString, Symbol>(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<Symbol>, CharSequence { private final String _underlying; - private static final ConcurrentHashMap<String, Symbol> _symbols = new ConcurrentHashMap<String, Symbol>(2048); + private static final ConcurrentMap<String, Symbol> _symbols = new ConcurrentHashMap<String, Symbol>(2048); private Symbol(String underlying) { |