diff options
Diffstat (limited to 'zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java')
| -rw-r--r-- | zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java index 62eded3ae..88bf0cc1c 100644 --- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java +++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/ServerCnxnFactory.java @@ -57,7 +57,7 @@ public abstract class ServerCnxnFactory { protected int maxCnxns; // sessionMap is used by closeSession() - final ConcurrentHashMap<Long, ServerCnxn> sessionMap = new ConcurrentHashMap<Long, ServerCnxn>(); + final ConcurrentHashMap<Long, ServerCnxn> sessionMap = new ConcurrentHashMap<>(); private static String loginUser = Login.SYSTEM_USER; @@ -198,11 +198,11 @@ public abstract class ServerCnxnFactory { public abstract Iterable<Map<String, Object>> getAllConnectionInfo(boolean brief); - private final ConcurrentHashMap<ServerCnxn, ConnectionBean> connectionBeans = new ConcurrentHashMap<ServerCnxn, ConnectionBean>(); + private final ConcurrentHashMap<ServerCnxn, ConnectionBean> connectionBeans = new ConcurrentHashMap<>(); // Connection set is relied on heavily by four letter commands // Construct a ConcurrentHashSet using a ConcurrentHashMap - protected final Set<ServerCnxn> cnxns = Collections.newSetFromMap(new ConcurrentHashMap<ServerCnxn, Boolean>()); + protected final Set<ServerCnxn> cnxns = Collections.newSetFromMap(new ConcurrentHashMap<>()); public void unregisterConnection(ServerCnxn serverCnxn) { ConnectionBean jmxConnectionBean = connectionBeans.remove(serverCnxn); if (jmxConnectionBean != null) { |