no need to spawn a thread when response to a ping response
This commit is contained in:
parent
fbea92e688
commit
a6d84f5942
|
@ -319,6 +319,12 @@ public class MasterFaultDetection extends AbstractComponent {
|
||||||
// send a response, and note if we are connected to the master or not
|
// send a response, and note if we are connected to the master or not
|
||||||
channel.sendResponse(new MasterPingResponseResponse(nodes.nodeExists(request.nodeId)));
|
channel.sendResponse(new MasterPingResponseResponse(nodes.nodeExists(request.nodeId)));
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
@Override public boolean spawn() {
|
||||||
|
// no need to spawn here, we just send a response
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
|
@ -266,6 +266,11 @@ public class NodesFaultDetection extends AbstractComponent {
|
||||||
}
|
}
|
||||||
channel.sendResponse(new PingResponse());
|
channel.sendResponse(new PingResponse());
|
||||||
}
|
}
|
||||||
|
|
||||||
|
@Override public boolean spawn() {
|
||||||
|
// no need to spawn here, we just send a response
|
||||||
|
return false;
|
||||||
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue