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.TimeoutChangedEvent
ILocationAware.Location
ILifecycle.DeferrableActivation
SIGNAL_MONITOR_CANCELED, SIGNAL_MONITOR_PROGRESS, SIGNAL_REMOTE_EXCEPTION, SIGNAL_SET_TIMEOUT
DEFAULT_TIMEOUT, NO_TIMEOUT
UNSPECIFIED_VERSION
Modifier | Constructor and Description |
---|---|
|
HeartBeatProtocol.Server() |
protected |
HeartBeatProtocol.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, doAfterActivate, doBeforeDeactivate, getStreamWrapper, getTimeout, handleBuffer, handleChannelDeactivation, isSendingTimeoutChanges, open, provideSignalReactor, setStreamWrapper, setTimeout, toString, waitForSignals
getBufferProvider, getChannel, getExecutorService, getInfraStructure, getLocation, getType, getUserID, getVersion, isClient, isServer, setChannel, setExecutorService, setInfraStructure, setUserID
activate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, doActivate, dump, getLifecycleState, isActive, isDeferredActivation
addListener, fireEvent, fireEvent, fireEvent, fireThrowable, firstListenerAdded, getListeners, getNotificationService, hasListeners, lastListenerRemoved, removeListener
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
getBufferProvider, getChannel, getExecutorService, getInfraStructure, getType, setChannel, setExecutorService, setInfraStructure
getUserID
getLocation, isClient, isServer
addListener, getListeners, hasListeners, removeListener
protected HeartBeatProtocol.Server(String type)
public HeartBeatProtocol.Server()
public Timer getHeartBeatTimer()
public void setHeartBeatTimer(Timer heartBeatTimer)
protected SignalReactor createSignalReactor(short signalID)
SignalProtocol
null
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>
Exception
protected void doDeactivate() throws Exception
doDeactivate
in class SignalProtocol<Object>
Exception
protected void indicatingStart(ExtendedDataInputStream in) throws IOException
IOException
Copyright (c) 2011, 2012 Eike Stepper (Berlin, Germany) and others.