Skip to content

Commit 57be456

Browse files
authored
Remove LegacyCTRAListener usage in NodeRemovalCSTE (#83797)
Relates #83784
1 parent 2d79dcc commit 57be456

File tree

1 file changed

+13
-2
lines changed

1 file changed

+13
-2
lines changed

server/src/main/java/org/elasticsearch/cluster/coordination/NodeRemovalClusterStateTaskExecutor.java

Lines changed: 13 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -9,6 +9,7 @@
99

1010
import org.apache.logging.log4j.LogManager;
1111
import org.apache.logging.log4j.Logger;
12+
import org.elasticsearch.action.ActionListener;
1213
import org.elasticsearch.cluster.ClusterState;
1314
import org.elasticsearch.cluster.ClusterStateTaskExecutor;
1415
import org.elasticsearch.cluster.ClusterStateTaskListener;
@@ -39,7 +40,7 @@ public void onNoLongerMaster() {
3940

4041
@Override
4142
public void clusterStateProcessed(ClusterState oldState, ClusterState newState) {
42-
onClusterStateProcessed.run();
43+
assert false : "not called";
4344
}
4445

4546
@Override
@@ -67,7 +68,17 @@ public ClusterTasksResult<Task> execute(final ClusterState currentState, final L
6768
} else {
6869
logger.debug("node [{}] does not exist in cluster state, ignoring", task);
6970
}
70-
resultBuilder.success(task, new LegacyClusterTaskResultActionListener(task, currentState));
71+
resultBuilder.success(task, new ActionListener<>() {
72+
@Override
73+
public void onResponse(ClusterState clusterState) {
74+
task.onClusterStateProcessed.run();
75+
}
76+
77+
@Override
78+
public void onFailure(Exception e) {
79+
task.onFailure(e);
80+
}
81+
});
7182
}
7283

7384
final ClusterState finalState;

0 commit comments

Comments
 (0)