Skip to content

Commit 5d35ba9

Browse files
committed
Fix on top of fix
1 parent cbb0884 commit 5d35ba9

File tree

3 files changed

+2
-18
lines changed

3 files changed

+2
-18
lines changed

server/src/main/java/org/elasticsearch/action/ActionModule.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -655,7 +655,6 @@ public <Request extends ActionRequest, Response extends ActionResponse> void reg
655655
actions.register(TransportDeleteDesiredBalanceAction.TYPE, TransportDeleteDesiredBalanceAction.class);
656656
actions.register(TransportClusterStatsAction.TYPE, TransportClusterStatsAction.class);
657657
actions.register(ClusterStateAction.INSTANCE, TransportClusterStateAction.class);
658-
actions.register(RemoteClusterStateAction.INSTANCE, TransportRemoteClusterStateAction.class);
659658
actions.register(TransportClusterHealthAction.TYPE, TransportClusterHealthAction.class);
660659
actions.register(ClusterUpdateSettingsAction.INSTANCE, TransportClusterUpdateSettingsAction.class);
661660
actions.register(ClusterGetSettingsAction.INSTANCE, TransportClusterGetSettingsAction.class);
@@ -1061,7 +1060,7 @@ protected void configure() {
10611060
bind(action.getTransportAction()).asEagerSingleton();
10621061
transportActionsBinder.addBinding(action.getAction()).to(action.getTransportAction()).asEagerSingleton();
10631062
}
1064-
1063+
bind(TransportRemoteClusterStateAction.class).asEagerSingleton();
10651064
}
10661065

10671066
public ActionFilters getActionFilters() {

server/src/main/java/org/elasticsearch/action/admin/cluster/state/RemoteClusterStateAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,7 +15,7 @@
1515
public class RemoteClusterStateAction extends ActionType<ClusterStateResponse> {
1616

1717
public static final RemoteClusterStateAction INSTANCE = new RemoteClusterStateAction();
18-
public static final String NAME = "cluster:monitor/state_remote";
18+
public static final String NAME = "cluster:monitor/state";
1919
public static final RemoteClusterActionType<ClusterStateResponse> REMOTE_TYPE = new RemoteClusterActionType<>(
2020
NAME,
2121
ClusterStateResponse::new

server/src/main/java/org/elasticsearch/action/admin/cluster/state/TransportClusterStateAction.java

Lines changed: 0 additions & 15 deletions
Original file line numberDiff line numberDiff line change
@@ -14,7 +14,6 @@
1414
import org.elasticsearch.action.ActionListener;
1515
import org.elasticsearch.action.ActionRunnable;
1616
import org.elasticsearch.action.support.ActionFilters;
17-
import org.elasticsearch.action.support.ChannelActionListener;
1817
import org.elasticsearch.action.support.local.TransportLocalClusterStateAction;
1918
import org.elasticsearch.cluster.ClusterState;
2019
import org.elasticsearch.cluster.ClusterStateObserver;
@@ -59,11 +58,6 @@ public class TransportClusterStateAction extends TransportLocalClusterStateActio
5958
private final IndexNameExpressionResolver indexNameExpressionResolver;
6059
private final ThreadPool threadPool;
6160

62-
/**
63-
* NB prior to 9.0 this was a TransportMasterNodeReadAction so for BwC it must be registered with the TransportService until
64-
* we no longer need to support calling this action remotely.
65-
*/
66-
@SuppressWarnings("this-escape")
6761
@Inject
6862
public TransportClusterStateAction(
6963
TransportService transportService,
@@ -83,15 +77,6 @@ public TransportClusterStateAction(
8377
this.projectResolver = projectResolver;
8478
this.indexNameExpressionResolver = indexNameExpressionResolver;
8579
this.threadPool = threadPool;
86-
87-
transportService.registerRequestHandler(
88-
actionName,
89-
executor,
90-
false,
91-
true,
92-
ClusterStateRequest::new,
93-
(request, channel, task) -> executeDirect(task, request, new ChannelActionListener<>(channel))
94-
);
9580
}
9681

9782
@Override

0 commit comments

Comments
 (0)