V
- public class RejoinAwareBlockingOperation<V> extends Object implements Callable<V>
Callable
implementation that accepts another callable delegate for executing it in nonstop+rejoin context.
Executing the call()
operation will execute the delegate callable and block until it returns. On rejoin, the delegate callable
is executed again.Constructor and Description |
---|
RejoinAwareBlockingOperation(ExecutorServiceStore executorServiceStore,
Callable<V> callable)
Public constructor
|
Modifier and Type | Method and Description |
---|---|
V |
call()
.
|
void |
clusterRejoined()
Called when cluster rejoin happens
|
public RejoinAwareBlockingOperation(ExecutorServiceStore executorServiceStore, Callable<V> callable)
executorServiceStore
- callable
- Copyright © 2003–2015 Terracotta, Inc.. All rights reserved.