public static class HeartBeatProtocol.Server extends SignalProtocol<Object>
heart beat protocol.| Modifier and Type | Class and Description |
|---|---|
static class |
HeartBeatProtocol.Server.Factory
Creates server-side
heart beat protocol instances. |
static class |
HeartBeatProtocol.Server.TimerInjector
|
SignalProtocol.TimeoutChangedEventILocationAware.LocationILifecycle.DeferrableActivationSIGNAL_MONITOR_CANCELED, SIGNAL_MONITOR_PROGRESS, SIGNAL_REMOTE_EXCEPTION, SIGNAL_SET_TIMEOUTDEFAULT_TIMEOUT, NO_TIMEOUTUNSPECIFIED_VERSION| Modifier | Constructor and Description |
|---|---|
|
Server() |
protected |
Server(String type) |
| Modifier and Type | Method and Description |
|---|---|
protected SignalReactor |
createSignalReactor(short signalID)
Returns a new signal instance to serve the given signal ID or
null if the signal ID is invalid/unknown
for this protocol. |
protected void |
doBeforeActivate() |
protected void |
doDeactivate() |
Timer |
getHeartBeatTimer() |
protected void |
indicatingStart(ExtendedDataInputStream in) |
void |
setHeartBeatTimer(Timer heartBeatTimer) |
addStreamWrapper, close, doBeforeDeactivate, getStreamWrapper, getTimeout, handleBuffer, handleChannelDeactivation, isSendingTimeoutChanges, open, provideSignalReactor, setStreamWrapper, setTimeout, setTimeout, toString, waitForSignalsgetBufferProvider, getChannel, getExecutorService, getInfraStructure, getLocation, getType, getUserID, getVersion, isClient, isServer, setChannel, setExecutorService, setInfraStructure, setUserIDactivate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, doActivate, doAfterActivate, dump, getLifecycleState, isActive, isDeferredActivationaddListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListeners, lastListenerRemoved, removeListenerclone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, waitgetBufferProvider, getChannel, getExecutorService, getInfraStructure, getType, setChannel, setExecutorService, setInfraStructuregetUserIDgetLocation, isClient, isServeraddListener, getListeners, hasListeners, removeListenerprotected Server(String type)
public Server()
public Timer getHeartBeatTimer()
public void setHeartBeatTimer(Timer heartBeatTimer)
protected SignalReactor createSignalReactor(short signalID)
SignalProtocolnull if the signal ID is invalid/unknown
for this protocol.createSignalReactor in class SignalProtocol<Object>protected void doBeforeActivate()
throws Exception
doBeforeActivate in class Protocol<Object>Exceptionprotected void doDeactivate()
throws Exception
doDeactivate in class SignalProtocol<Object>Exceptionprotected void indicatingStart(ExtendedDataInputStream in) throws IOException
IOExceptionCopyright (c) 2011-2015 Eike Stepper (Berlin, Germany) and others.