From ffb3e0a8452320e9a3b101f0e1f69db6fdcea127 Mon Sep 17 00:00:00 2001
From: Jason Tedor <jason@tedor.me>
Date: Wed, 25 Nov 2015 17:44:28 -0500
Subject: [PATCH] ClusterStateTaskListener#onNoLongerMaster now throws
 NotMasterException

---
 .../org/elasticsearch/cluster/ClusterStateTaskListener.java     | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/core/src/main/java/org/elasticsearch/cluster/ClusterStateTaskListener.java b/core/src/main/java/org/elasticsearch/cluster/ClusterStateTaskListener.java
index 16945d91971..612fde60d43 100644
--- a/core/src/main/java/org/elasticsearch/cluster/ClusterStateTaskListener.java
+++ b/core/src/main/java/org/elasticsearch/cluster/ClusterStateTaskListener.java
@@ -33,7 +33,7 @@ public interface ClusterStateTaskListener {
      * called when the task was rejected because the local node is no longer master
      */
     default void onNoLongerMaster(String source) {
-        onFailure(source, new EsRejectedExecutionException("no longer master. source: [" + source + "]"));
+        onFailure(source, new NotMasterException("no longer master. source: [" + source + "]"));
     }
 
     /**