THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
@Override public void run() { Throwable err = null; try { // Critical worker's code. } catch(Throwable e) { err = e; } finally { // Call failure handler. FailureContext failureCtx = new FaulureCtx(FailureType.SYSTEM_WORKER_TERMINATION, err); FailureHandler failureHnd = failureHandler();ctx.failure().process(failureCtx); // GetHandle failure handler configured by user. Where ctx - failureHnd.onFailure(ignite, failureCtx); // Handle failurekernal context. } } |
...