public static class HeartBeatProtocol.Server extends SignalProtocol<java.lang.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.DeferrableActivationCOMPRESSED_STRINGS_ACKNOWLEDGE_TIMEOUT, SIGNAL_ACKNOWLEDGE_COMPRESSED_STRINGS, SIGNAL_MONITOR_CANCELED, SIGNAL_MONITOR_PROGRESS, SIGNAL_REMOTE_EXCEPTION, SIGNAL_SET_TIMEOUTDEFAULT_TIMEOUT, NO_TIMEOUTUNSPECIFIED_VERSION| Modifier | Constructor and Description |
|---|---|
|
Server() |
protected |
Server(java.lang.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() |
java.util.Timer |
getHeartBeatTimer() |
protected void |
indicatingStart(ExtendedDataInputStream in) |
void |
setHeartBeatTimer(java.util.Timer heartBeatTimer) |
addStreamWrapper, close, doBeforeDeactivate, getStreamWrapper, getStringCompressor, 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, removeListenerpublic java.util.Timer getHeartBeatTimer()
public void setHeartBeatTimer(java.util.Timer heartBeatTimer)
protected SignalReactor createSignalReactor(short signalID)
SignalProtocolnull if the signal ID is invalid/unknown
for this protocol.createSignalReactor in class SignalProtocol<java.lang.Object>protected void doBeforeActivate()
throws java.lang.Exception
doBeforeActivate in class Protocol<java.lang.Object>java.lang.Exceptionprotected void doDeactivate()
throws java.lang.Exception
doDeactivate in class SignalProtocol<java.lang.Object>java.lang.Exceptionprotected void indicatingStart(ExtendedDataInputStream in) throws java.io.IOException
java.io.IOExceptionCopyright (c) 2004-2019 Eike Stepper (Loehne, Germany) and others.
All rights reserved. This program and the accompanying materials are made available under the terms of the Eclipse Public License v1.0 which accompanies this distribution, and is available at http://www.eclipse.org/legal/epl-v10.html