com.epam.bovespafast.impl.manager.recovery

Class AbstractManager

java.lang.Object

com.epam.bovespafast.impl.manager.recovery.AbstractManager

All Implemented Interfaces:

RecoveryManager

Direct Known Subclasses:

ForcedHistoricalRecoveryManager, GlobalTCPHistoricalRecoveryManager, HistoricalRecoveryManager, NoneRecoveryManager, SnapshotRecoveryStreamManager

public abstract class AbstractManager
extends Object
implements RecoveryManager

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelContext	context
protected com.epam.common.logging.Log	log
protected StreamTransport	recoveryTransport

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractManager(ChannelContext context)

Method Summary

Modifier and Type	Method and Description
Queue<com.epam.fastadaptor.util.queue.MessageHolder>	getMessageQueue()
boolean	isRun()
void	setRun(boolean run)

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epam.bovespafast.impl.manager.recovery.RecoveryManager

setRecoveryListener, startRecovery, stop, stopRecovery

Field Detail

log

protected final com.epam.common.logging.Log log

recoveryTransport

protected StreamTransport recoveryTransport

context

protected final ChannelContext context

Constructor Detail

AbstractManager

protected AbstractManager(ChannelContext context)

Method Detail

getMessageQueue

public Queue<com.epam.fastadaptor.util.queue.MessageHolder> getMessageQueue()

isRun

public boolean isRun()

setRun

public void setRun(boolean run)