From a89f7014aeb71dba5c94404dfea7eb89e7eeee74 Mon Sep 17 00:00:00 2001
From: Jean-Noel Rouvignac <jean-noel.rouvignac@forgerock.com>
Date: Wed, 08 Jul 2015 06:48:02 +0000
Subject: [PATCH] AutoRefactor'ed Use Diamond Operator
---
opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java | 38 ++++++++++----------------------------
1 files changed, 10 insertions(+), 28 deletions(-)
diff --git a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
index 81d5c9a..a0b66d6 100644
--- a/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
+++ b/opendj-server-legacy/src/main/java/org/opends/server/replication/plugin/MultimasterReplication.java
@@ -103,42 +103,24 @@
private static final LocalizedLogger logger = LocalizedLogger.getLoggerForThisClass();
private ReplicationServerListener replicationServerListener;
- private static final Map<DN, LDAPReplicationDomain> domains =
- new ConcurrentHashMap<DN, LDAPReplicationDomain>(4);
+ private static final Map<DN, LDAPReplicationDomain> domains = new ConcurrentHashMap<>(4);
private static final DSRSShutdownSync dsrsShutdownSync = new DSRSShutdownSync();
-
- /**
- * The queue of received update messages, to be treated by the ReplayThread
- * threads.
- */
- private static final BlockingQueue<UpdateToReplay> updateToReplayQueue =
- new LinkedBlockingQueue<UpdateToReplay>(10000);
-
- /**
- * The list of ReplayThread threads.
- */
- private static final List<ReplayThread> replayThreads =
- new ArrayList<ReplayThread>();
-
- /**
- * The configurable number of replay threads.
- */
+ /** The queue of received update messages, to be treated by the ReplayThread threads. */
+ private static final BlockingQueue<UpdateToReplay> updateToReplayQueue = new LinkedBlockingQueue<>(10000);
+ /** The list of ReplayThread threads. */
+ private static final List<ReplayThread> replayThreads = new ArrayList<>();
+ /** The configurable number of replay threads. */
private static int replayThreadNumber = 10;
- /**
- * Enum that symbolizes the state of the multimaster replication.
- */
+ /** Enum that symbolizes the state of the multimaster replication. */
private static enum State
{
STARTING, RUNNING, STOPPING
}
- private static final AtomicReference<State> state =
- new AtomicReference<State>(State.STARTING);
+ private static final AtomicReference<State> state = new AtomicReference<>(State.STARTING);
- /**
- * The configurable connection/handshake timeout.
- */
+ /** The configurable connection/handshake timeout. */
private static volatile int connectionTimeoutMS = 5000;
/**
@@ -857,7 +839,7 @@
*/
public static Set<DN> getExcludedChangelogDomains() throws DirectoryException
{
- final Set<DN> disabledBaseDNs = new HashSet<DN>(domains.size() + 1);
+ final Set<DN> disabledBaseDNs = new HashSet<>(domains.size() + 1);
disabledBaseDNs.add(DN.valueOf(DN_EXTERNAL_CHANGELOG_ROOT));
for (LDAPReplicationDomain domain : domains.values())
{
--
Gitblit v1.10.0