diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/SinglePingRequest.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/SinglePingRequest.java index 3db6d0d5a1a..6b5613b2022 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/SinglePingRequest.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/SinglePingRequest.java @@ -19,7 +19,7 @@ package org.elasticsearch.action.admin.cluster.ping.single; -import org.elasticsearch.action.support.single.SingleOperationRequest; +import org.elasticsearch.action.support.single.shard.SingleOperationRequest; import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/TransportSinglePingAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/TransportSinglePingAction.java index ebab4d15ae6..002cee5e70b 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/TransportSinglePingAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/admin/cluster/ping/single/TransportSinglePingAction.java @@ -21,21 +21,20 @@ package org.elasticsearch.action.admin.cluster.ping.single; import org.elasticsearch.ElasticSearchException; import org.elasticsearch.action.TransportActions; -import org.elasticsearch.action.support.single.TransportSingleOperationAction; +import org.elasticsearch.action.support.single.shard.TransportSingleOperationAction; import org.elasticsearch.cluster.ClusterService; import org.elasticsearch.common.inject.Inject; import org.elasticsearch.common.settings.Settings; -import org.elasticsearch.indices.IndicesService; import org.elasticsearch.threadpool.ThreadPool; import org.elasticsearch.transport.TransportService; /** - * @author kimchy (Shay Banon) + * @author kimchy (shay.banon) */ public class TransportSinglePingAction extends TransportSingleOperationAction { - @Inject public TransportSinglePingAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService, IndicesService indicesService) { - super(settings, threadPool, clusterService, transportService, indicesService); + @Inject public TransportSinglePingAction(Settings settings, ThreadPool threadPool, ClusterService clusterService, TransportService transportService) { + super(settings, threadPool, clusterService, transportService); } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/GetRequest.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/GetRequest.java index 78636eacb26..4c537aaca35 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/GetRequest.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/GetRequest.java @@ -19,7 +19,7 @@ package org.elasticsearch.action.get; -import org.elasticsearch.action.support.single.SingleOperationRequest; +import org.elasticsearch.action.support.single.shard.SingleOperationRequest; import org.elasticsearch.common.Required; import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/TransportGetAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/TransportGetAction.java index e176b0b4596..18c2e50c608 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/TransportGetAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/get/TransportGetAction.java @@ -24,7 +24,7 @@ import org.apache.lucene.document.FieldSelector; import org.apache.lucene.document.Fieldable; import org.elasticsearch.ElasticSearchException; import org.elasticsearch.action.TransportActions; -import org.elasticsearch.action.support.single.TransportSingleOperationAction; +import org.elasticsearch.action.support.single.shard.TransportSingleOperationAction; import org.elasticsearch.cluster.ClusterService; import org.elasticsearch.cluster.ClusterState; import org.elasticsearch.cluster.block.ClusterBlockLevel; @@ -52,9 +52,12 @@ import static org.elasticsearch.common.collect.Maps.*; */ public class TransportGetAction extends TransportSingleOperationAction { + private final IndicesService indicesService; + @Inject public TransportGetAction(Settings settings, ClusterService clusterService, TransportService transportService, IndicesService indicesService, ThreadPool threadPool) { - super(settings, threadPool, clusterService, transportService, indicesService); + super(settings, threadPool, clusterService, transportService); + this.indicesService = indicesService; } @Override protected String transportAction() { diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/SingleOperationRequest.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/SingleOperationRequest.java similarity index 98% rename from modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/SingleOperationRequest.java rename to modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/SingleOperationRequest.java index fa84364ced8..4d952b7b2e1 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/SingleOperationRequest.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/SingleOperationRequest.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.action.support.single; +package org.elasticsearch.action.support.single.shard; import org.elasticsearch.action.ActionRequest; import org.elasticsearch.action.ActionRequestValidationException; diff --git a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/TransportSingleOperationAction.java b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/TransportSingleOperationAction.java similarity index 97% rename from modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/TransportSingleOperationAction.java rename to modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/TransportSingleOperationAction.java index 17a6e3d3bd3..d238d34cdd2 100644 --- a/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/TransportSingleOperationAction.java +++ b/modules/elasticsearch/src/main/java/org/elasticsearch/action/support/single/shard/TransportSingleOperationAction.java @@ -17,7 +17,7 @@ * under the License. */ -package org.elasticsearch.action.support.single; +package org.elasticsearch.action.support.single.shard; import org.elasticsearch.ElasticSearchException; import org.elasticsearch.action.ActionListener; @@ -34,7 +34,6 @@ import org.elasticsearch.common.io.stream.StreamInput; import org.elasticsearch.common.io.stream.StreamOutput; import org.elasticsearch.common.io.stream.Streamable; import org.elasticsearch.common.settings.Settings; -import org.elasticsearch.indices.IndicesService; import org.elasticsearch.threadpool.ThreadPool; import org.elasticsearch.transport.*; @@ -49,16 +48,13 @@ public abstract class TransportSingleOperationAction