Stop sending events after knowing node failure

This patch aims to stop sending events to a node after knowing that node is failed.
walmartlabs · May 7, 2015 · 78397ea · 78397ea
1 parent 427bb1c
commit 78397ea
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/src/main/scala/com/walmartlabs/mupd8/MUCluster.scala b/src/main/scala/com/walmartlabs/mupd8/MUCluster.scala
@@ -57,12 +57,15 @@ class MUCluster[T <: MapUpdateClass[T]](self: Host,
 
   def send(dest: Host, obj: T) {
     def _send(retryCount: Int, destip: String, obj: T): Boolean = {
-      if (retryCount == 0) {
+      if (appRun.candidateRing != null && !appRun.candidateRing.ips.contains(destip)) {
+        warn("Did not send this event, because its destination may not be accessible and will be removed from the ring")
+        false
+      } else if (retryCount == 0) {
         false
       } else {
         if (!client.send(destip, obj)) {
           warn("Failed to send event (" + obj + ") to destination " + destip + " at retry : " + retryCount)
-          Thread.sleep(10000)
+          Thread.sleep(5000)
           _send(retryCount - 1, destip, obj)
         } else {
           true