completed renaming of MetaDataStateIndexService to MetaDataIndexStateService
This commit is contained in:
parent
8eed6cdcae
commit
3b2a9fc86b
|
@ -38,15 +38,15 @@ import org.elasticsearch.transport.TransportService;
|
|||
*/
|
||||
public class TransportCloseIndexAction extends TransportMasterNodeOperationAction<CloseIndexRequest, CloseIndexResponse> {
|
||||
|
||||
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<CloseIndexResponse> 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()));
|
||||
|
|
|
@ -37,13 +37,13 @@ import org.elasticsearch.transport.TransportService;
|
|||
*/
|
||||
public class TransportOpenIndexAction extends TransportMasterNodeOperationAction<OpenIndexRequest, OpenIndexResponse> {
|
||||
|
||||
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<OpenIndexResponse> 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()));
|
||||
|
|
Loading…
Reference in New Issue