Package com.adaptris.failover

Class FailoverManager

java.lang.Object

com.adaptris.failover.FailoverManager

All Implemented Interfaces:

PingEventListener, StateChangeEventSender, Triggerable

public class FailoverManager
extends java.lang.Object
implements PingEventListener, StateChangeEventSender, Triggerable

Field Summary

Fields

Modifier and Type	Field	Description
protected org.slf4j.Logger	log

Constructor Summary

Constructors

Constructor	Description
FailoverManager(java.lang.String myHost, java.lang.String myPort, Listener listener, Broadcaster broadcaster, boolean primary, int secondaryPosition)

Method Summary

Modifier and Type	Method	Description
boolean	equals(PingEventListener eventListener)
OnlineInstance	getCurrentPrimary()
java.util.List<OnlineInstance>	getInstances()
int	getInstanceTimeoutSeconds()
MultiPrimaryConflictHandler	getMultiPrimaryConflictHandler()
OnlineInstance	getMyInstance()
MonitorThread	getPollingThread()
java.util.UUID	getUniqueId()
void	notifyAdapterStopped()
void	notifyPromoteSecondary()
void	notifyPromoteToPrimary()
void	pollTriggered()
void	primaryPinged(Ping ping)
void	registerListener(StateChangeEventListener listener)
void	secondaryPinged(Ping ping)
void	setCurrentPrimary(OnlineInstance currentPrimary)
void	setInstances(java.util.List<OnlineInstance> instances)
void	setInstanceTimeoutSeconds(int instanceTimeoutSeconds)
void	setMultiPrimaryConflictHandler(MultiPrimaryConflictHandler multiPrimaryConflictHandler)
void	setMyInstance(OnlineInstance myInstance)
void	setPollingThread(MonitorThread pollingThread)
void	setUniqueId(java.util.UUID uniqueId)
void	start()
void	stop()
void	stopFailoverManager()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

log

protected transient org.slf4j.Logger log

Constructor Detail

FailoverManager

public FailoverManager(java.lang.String myHost,
                       java.lang.String myPort,
                       Listener listener,
                       Broadcaster broadcaster,
                       boolean primary,
                       int secondaryPosition)

Method Detail

pollTriggered

public void pollTriggered()

Specified by:

pollTriggered in interface Triggerable

start

public void start()
           throws java.lang.Exception

Throws:

java.lang.Exception

stopFailoverManager

public void stopFailoverManager()

stop

public void stop()

primaryPinged

public void primaryPinged(Ping ping)

Specified by:

primaryPinged in interface PingEventListener

secondaryPinged

public void secondaryPinged(Ping ping)

Specified by:

secondaryPinged in interface PingEventListener

equals

public boolean equals(PingEventListener eventListener)

Specified by:

equals in interface PingEventListener

notifyPromoteToPrimary

public void notifyPromoteToPrimary()

Specified by:

notifyPromoteToPrimary in interface StateChangeEventSender

notifyPromoteSecondary

public void notifyPromoteSecondary()

Specified by:

notifyPromoteSecondary in interface StateChangeEventSender

notifyAdapterStopped

public void notifyAdapterStopped()

Specified by:

notifyAdapterStopped in interface StateChangeEventSender

registerListener

public void registerListener(StateChangeEventListener listener)

Specified by:

registerListener in interface StateChangeEventSender

getUniqueId

public java.util.UUID getUniqueId()

setUniqueId

public void setUniqueId(java.util.UUID uniqueId)

getInstanceTimeoutSeconds

public int getInstanceTimeoutSeconds()

setInstanceTimeoutSeconds

public void setInstanceTimeoutSeconds(int instanceTimeoutSeconds)

getPollingThread

public MonitorThread getPollingThread()

setPollingThread

public void setPollingThread(MonitorThread pollingThread)

getMyInstance

public OnlineInstance getMyInstance()

setMyInstance

public void setMyInstance(OnlineInstance myInstance)

getCurrentPrimary

public OnlineInstance getCurrentPrimary()

setCurrentPrimary

public void setCurrentPrimary(OnlineInstance currentPrimary)

getInstances

public java.util.List<OnlineInstance> getInstances()

setInstances

public void setInstances(java.util.List<OnlineInstance> instances)

getMultiPrimaryConflictHandler

public MultiPrimaryConflictHandler getMultiPrimaryConflictHandler()

setMultiPrimaryConflictHandler

public void setMultiPrimaryConflictHandler(MultiPrimaryConflictHandler multiPrimaryConflictHandler)