summaryrefslogtreecommitdiff
path: root/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java
diff options
context:
space:
mode:
Diffstat (limited to 'zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java')
-rw-r--r--zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java4
1 files changed, 2 insertions, 2 deletions
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java
index fb5dbcc36..66dfcbae7 100644
--- a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java
+++ b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/UpgradeableSessionTracker.java
@@ -44,9 +44,9 @@ public abstract class UpgradeableSessionTracker implements SessionTracker {
}
public void createLocalSessionTracker(SessionExpirer expirer, int tickTime, long id, ZooKeeperServerListener listener) {
- this.localSessionsWithTimeouts = new ConcurrentHashMap<Long, Integer>();
+ this.localSessionsWithTimeouts = new ConcurrentHashMap<>();
this.localSessionTracker = new LocalSessionTracker(expirer, this.localSessionsWithTimeouts, tickTime, id, listener);
- this.upgradingSessions = new ConcurrentHashMap<Long, Integer>();
+ this.upgradingSessions = new ConcurrentHashMap<>();
}
public boolean isTrackingSession(long sessionId) {