From 78d7e5b6957719304a154807e1aae0f84acd7f18 Mon Sep 17 00:00:00 2001 From: Simon Willnauer Date: Tue, 19 May 2015 14:53:39 +0200 Subject: [PATCH] Minor cleanups in SyncedFlushService --- .../elasticsearch/indices/SyncedFlushService.java | 15 ++++++--------- 1 file changed, 6 insertions(+), 9 deletions(-) diff --git a/src/main/java/org/elasticsearch/indices/SyncedFlushService.java b/src/main/java/org/elasticsearch/indices/SyncedFlushService.java index fc0a1b50df1..1821da0e2bc 100644 --- a/src/main/java/org/elasticsearch/indices/SyncedFlushService.java +++ b/src/main/java/org/elasticsearch/indices/SyncedFlushService.java @@ -59,9 +59,9 @@ import java.util.concurrent.atomic.AtomicInteger; public class SyncedFlushService extends AbstractComponent { - public static final String PRE_SYNCED_FLUSH_ACTION_NAME = "internal:indices/flush/synced/pre"; - public static final String SYNCED_FLUSH_ACTION_NAME = "internal:indices/flush/synced/sync"; - public static final String IN_FLIGHT_OPS_ACTION_NAME = "internal:indices/flush/synced/in_flight"; + private static final String PRE_SYNCED_FLUSH_ACTION_NAME = "internal:indices/flush/synced/pre"; + private static final String SYNCED_FLUSH_ACTION_NAME = "internal:indices/flush/synced/sync"; + private static final String IN_FLIGHT_OPS_ACTION_NAME = "internal:indices/flush/synced/in_flight"; private final IndicesService indicesService; private final ClusterService clusterService; @@ -693,7 +693,6 @@ public class SyncedFlushService extends AbstractComponent { int opCount; - public InFlightOpsResponse() { } @@ -725,8 +724,7 @@ public class SyncedFlushService extends AbstractComponent { } } - - private class PreSyncedFlushTransportHandler implements TransportRequestHandler { + private final class PreSyncedFlushTransportHandler implements TransportRequestHandler { @Override public void messageReceived(PreSyncedFlushRequest request, TransportChannel channel) throws Exception { @@ -734,8 +732,7 @@ public class SyncedFlushService extends AbstractComponent { } } - - private class SyncedFlushTransportHandler implements TransportRequestHandler { + private final class SyncedFlushTransportHandler implements TransportRequestHandler { @Override public void messageReceived(SyncedFlushRequest request, TransportChannel channel) throws Exception { @@ -743,7 +740,7 @@ public class SyncedFlushService extends AbstractComponent { } } - private class InFlightOpCountTransportHandler implements TransportRequestHandler { + private final class InFlightOpCountTransportHandler implements TransportRequestHandler { @Override public void messageReceived(InFlightOpsRequest request, TransportChannel channel) throws Exception {