org.eclipse.net4j.signal.heartbeat
Class HeartBeatProtocol.Server
java.lang.Object
org.eclipse.net4j.util.event.Notifier
org.eclipse.net4j.util.lifecycle.Lifecycle
org.eclipse.spi.net4j.Protocol<INFRA_STRUCTURE>
org.eclipse.net4j.signal.SignalProtocol<Object>
org.eclipse.net4j.signal.heartbeat.HeartBeatProtocol.Server
- All Implemented Interfaces:
- IBufferHandler, ILocationAware, IProtocol<Object>, ISignalProtocol<Object>, INotifier, ILifecycle, ILifecycle.DeferrableActivation, IUserAware
- Enclosing class:
- HeartBeatProtocol
- public static class HeartBeatProtocol.Server
- extends SignalProtocol<Object>
The server-side implementation of a heart beat protocol
.
Methods inherited from class org.eclipse.net4j.signal.SignalProtocol |
addStreamWrapper, close, doAfterActivate, doBeforeDeactivate, getStreamWrapper, getTimeout, handleBuffer, handleChannelDeactivation, isSendingTimeoutChanges, open, provideSignalReactor, setStreamWrapper, setTimeout, toString, waitForSignals |
Methods inherited from class org.eclipse.spi.net4j.Protocol |
getBufferProvider, getChannel, getExecutorService, getInfraStructure, getLocation, getType, getUserID, isClient, isServer, setChannel, setExecutorService, setInfraStructure, setUserID |
Methods inherited from class org.eclipse.net4j.util.lifecycle.Lifecycle |
activate, checkActive, checkArg, checkArg, checkInactive, checkNull, checkState, checkState, deactivate, deferredActivate, doActivate, dump, getLifecycleState, isActive, isDeferredActivation |
HeartBeatProtocol.Server
protected HeartBeatProtocol.Server(String type)
- Since:
- 4.0
HeartBeatProtocol.Server
public HeartBeatProtocol.Server()
getHeartBeatTimer
public Timer getHeartBeatTimer()
setHeartBeatTimer
public void setHeartBeatTimer(Timer heartBeatTimer)
createSignalReactor
protected SignalReactor createSignalReactor(short signalID)
- Description copied from class:
SignalProtocol
- Returns a new signal instance to serve the given signal ID or
null
if the signal ID is invalid/unknown
for this protocol.
- Overrides:
createSignalReactor
in class SignalProtocol<Object>
doBeforeActivate
protected void doBeforeActivate()
throws Exception
- Overrides:
doBeforeActivate
in class Protocol<Object>
- Throws:
Exception
doDeactivate
protected void doDeactivate()
throws Exception
- Overrides:
doDeactivate
in class SignalProtocol<Object>
- Throws:
Exception
indicatingStart
protected void indicatingStart(ExtendedDataInputStream in)
throws IOException
- Throws:
IOException
- Since:
- 4.0
Copyright (c) 2004 - 2012 Eike Stepper (Berlin, Germany) and others.