public static class FailoverAgent.Protocol extends HeartBeatProtocol
fail-over monitor protocol.HeartBeatProtocol.ServerSignalProtocol.InvalidSignalIDException, SignalProtocol.TimeoutChangedEventILocationAware.LocationILifecycle.DeferrableActivationTYPECOMPRESSED_STRINGS_ACKNOWLEDGE_TIMEOUT, SIGNAL_ACKNOWLEDGE_COMPRESSED_STRINGS, SIGNAL_MONITOR_CANCELED, SIGNAL_MONITOR_PROGRESS, SIGNAL_REMOTE_EXCEPTION, SIGNAL_SET_TIMEOUTDEFAULT_TIMEOUT, NO_TIMEOUTUNSPECIFIED_VERSION| Constructor and Description |
|---|
Protocol(FailoverAgent agent) |
| Modifier and Type | Method and Description |
|---|---|
protected SignalReactor |
createSignalReactor(short signalID) |
FailoverAgent |
getAgent() |
protected void |
requestingStart(ExtendedDataOutputStream out,
long rate) |
doDeactivate, getDefaultTimer, getTimer, handleTimeout, start, startaddStreamWrapper, close, doBeforeDeactivate, getStreamWrapper, getStringCompressor, getTimeout, handleBuffer, handleChannelDeactivation, isSendingTimeoutChanges, open, provideSignalReactor, setStreamWrapper, setTimeout, setTimeout, toString, waitForSignalsdoBeforeActivate, getBufferProvider, 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 Protocol(FailoverAgent agent)
public FailoverAgent getAgent()
protected void requestingStart(ExtendedDataOutputStream out, long rate) throws java.io.IOException
requestingStart in class HeartBeatProtocoljava.io.IOExceptionprotected SignalReactor createSignalReactor(short signalID)
createSignalReactor in class HeartBeatProtocolCopyright (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