public class OpenCallbacksManager extends Object
Constructor and Description |
---|
OpenCallbacksManager(Object lock,
StatisticsImpl statistics,
ScheduledExecutorService executor) |
Modifier and Type | Method and Description |
---|---|
protected void |
closeFuture(NotifyFuture<Callback[]> future) |
void |
disconnected() |
NotifyFuture<Callback[]> |
processCallbacks(CallbackHandler callbackHandler,
Callback[] callbacks,
Long timeout) |
public OpenCallbacksManager(Object lock, StatisticsImpl statistics, ScheduledExecutorService executor)
public void disconnected()
public NotifyFuture<Callback[]> processCallbacks(CallbackHandler callbackHandler, Callback[] callbacks, Long timeout)
protected void closeFuture(NotifyFuture<Callback[]> future)