ClusterStateTaskListener#onNoLongerMaster now throws NotMasterException

This commit is contained in:
Jason Tedor 2015-11-25 17:44:28 -05:00
parent 72e18ec681
commit ffb3e0a845
1 changed files with 1 additions and 1 deletions

View File

@ -33,7 +33,7 @@ public interface ClusterStateTaskListener {
* called when the task was rejected because the local node is no longer master * called when the task was rejected because the local node is no longer master
*/ */
default void onNoLongerMaster(String source) { default void onNoLongerMaster(String source) {
onFailure(source, new EsRejectedExecutionException("no longer master. source: [" + source + "]")); onFailure(source, new NotMasterException("no longer master. source: [" + source + "]"));
} }
/** /**