diff --git a/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java b/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java index c8352158af3..f625d7ddab5 100644 --- a/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java +++ b/src/main/java/org/elasticsearch/action/admin/indices/close/TransportCloseIndexAction.java @@ -38,15 +38,15 @@ import org.elasticsearch.transport.TransportService; */ public class TransportCloseIndexAction extends TransportMasterNodeOperationAction { - private final MetaDataIndexStateService stateIndexService; + private final MetaDataIndexStateService indexStateService; private final boolean disableCloseAllIndices; @Inject public TransportCloseIndexAction(Settings settings, TransportService transportService, ClusterService clusterService, - ThreadPool threadPool, MetaDataIndexStateService stateIndexService) { + ThreadPool threadPool, MetaDataIndexStateService indexStateService) { super(settings, transportService, clusterService, threadPool); - this.stateIndexService = stateIndexService; + this.indexStateService = indexStateService; this.disableCloseAllIndices = settings.getAsBoolean("action.disable_close_all_indices", false); } @@ -94,7 +94,7 @@ public class TransportCloseIndexAction extends TransportMasterNodeOperationActio @Override protected void masterOperation(final CloseIndexRequest request, final ClusterState state, final ActionListener listener) throws ElasticSearchException { - stateIndexService.closeIndex(new MetaDataIndexStateService.Request(request.indices()).timeout(request.timeout()).masterTimeout(request.masterNodeTimeout()), new MetaDataIndexStateService.Listener() { + indexStateService.closeIndex(new MetaDataIndexStateService.Request(request.indices()).timeout(request.timeout()).masterTimeout(request.masterNodeTimeout()), new MetaDataIndexStateService.Listener() { @Override public void onResponse(MetaDataIndexStateService.Response response) { listener.onResponse(new CloseIndexResponse(response.acknowledged())); diff --git a/src/main/java/org/elasticsearch/action/admin/indices/open/TransportOpenIndexAction.java b/src/main/java/org/elasticsearch/action/admin/indices/open/TransportOpenIndexAction.java index befaebda4e1..3d771253a3b 100644 --- a/src/main/java/org/elasticsearch/action/admin/indices/open/TransportOpenIndexAction.java +++ b/src/main/java/org/elasticsearch/action/admin/indices/open/TransportOpenIndexAction.java @@ -37,13 +37,13 @@ import org.elasticsearch.transport.TransportService; */ public class TransportOpenIndexAction extends TransportMasterNodeOperationAction { - private final MetaDataIndexStateService stateIndexService; + private final MetaDataIndexStateService indexStateService; @Inject public TransportOpenIndexAction(Settings settings, TransportService transportService, ClusterService clusterService, - ThreadPool threadPool, MetaDataIndexStateService stateIndexService) { + ThreadPool threadPool, MetaDataIndexStateService indexStateService) { super(settings, transportService, clusterService, threadPool); - this.stateIndexService = stateIndexService; + this.indexStateService = indexStateService; } @Override @@ -80,7 +80,7 @@ public class TransportOpenIndexAction extends TransportMasterNodeOperationAction @Override protected void masterOperation(final OpenIndexRequest request, final ClusterState state, final ActionListener listener) throws ElasticSearchException { - stateIndexService.openIndex(new MetaDataIndexStateService.Request(request.indices()).timeout(request.timeout()).masterTimeout(request.masterNodeTimeout()), new MetaDataIndexStateService.Listener() { + indexStateService.openIndex(new MetaDataIndexStateService.Request(request.indices()).timeout(request.timeout()).masterTimeout(request.masterNodeTimeout()), new MetaDataIndexStateService.Listener() { @Override public void onResponse(MetaDataIndexStateService.Response response) { listener.onResponse(new OpenIndexResponse(response.acknowledged()));