com.epam.bovespafast.impl.context

Class ChannelContext

java.lang.Object

com.epam.bovespafast.impl.context.ChannelContext

public class ChannelContext
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected static com.epam.common.logging.Log	LOG
protected RecoveryOptions	recoveryOptions

Constructor Summary

Constructors

Constructor and Description
ChannelContext(AbstractChannel abstractChannel)

Method Summary

Modifier and Type	Method and Description
AbstractChannel	getChannel()
FASTChannelFactory	getChannelFactory()
String	getChannelId()
InstrumentListener	getInstrumentListener()
InstrumentStorage	getInstrumentStorage()
MessageChopper	getMessageChopper()
MessageListener	getMessageListener()
RecoveryManager	getRecoveryManager()
RecoveryOptions	getRecoveryOptions()
com.epam.fast.full.coders.stream.SeqNumHelper	getSecNumHelper()
StateProcessor	getStateProcessor()
TransportMessageSubscriber	getTransportMessageSubscriber()
void	notifyComponentError()
void	notifyComponentErrorEnded()
void	processNewState(Instrument instr, State state)
void	setChannelFactory(FASTChannelFactory channelFactory)
void	setChannelId(String channelId)
void	setInstrumentStorage(InstrumentStorage instrumentStorage)
void	setMessageChopper(MessageChopper messageChopper)
void	setRecoveryOptions(RecoveryOptions recoveryOptions)
void	startRecoveryFeed()
void	stopFeeds()
void	stopRecoveryFeed(Instrument instrument)

Methods inherited from class java.lang.Object

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

Field Detail

LOG

protected static final com.epam.common.logging.Log LOG

recoveryOptions

protected RecoveryOptions recoveryOptions

Constructor Detail

ChannelContext

public ChannelContext(AbstractChannel abstractChannel)

Method Detail

getRecoveryOptions

public RecoveryOptions getRecoveryOptions()

setRecoveryOptions

public void setRecoveryOptions(RecoveryOptions recoveryOptions)

getInstrumentStorage

public InstrumentStorage getInstrumentStorage()

setInstrumentStorage

public void setInstrumentStorage(InstrumentStorage instrumentStorage)

getMessageChopper

public MessageChopper getMessageChopper()

setMessageChopper

public void setMessageChopper(MessageChopper messageChopper)

getChannelId

public String getChannelId()

setChannelId

public void setChannelId(String channelId)

startRecoveryFeed

public void startRecoveryFeed()
                       throws IOException

Throws:

IOException

processNewState

public void processNewState(Instrument instr,
                            State state)

stopRecoveryFeed

public void stopRecoveryFeed(Instrument instrument)
                      throws IOException

Throws:

IOException

stopFeeds

public void stopFeeds()
               throws IOException

Throws:

IOException

getInstrumentListener

public InstrumentListener getInstrumentListener()

getStateProcessor

public StateProcessor getStateProcessor()

getRecoveryManager

public RecoveryManager getRecoveryManager()

getMessageListener

public MessageListener getMessageListener()

getTransportMessageSubscriber

public TransportMessageSubscriber getTransportMessageSubscriber()

setChannelFactory

public void setChannelFactory(FASTChannelFactory channelFactory)

getChannelFactory

public FASTChannelFactory getChannelFactory()

getSecNumHelper

public com.epam.fast.full.coders.stream.SeqNumHelper getSecNumHelper()

getChannel

public AbstractChannel getChannel()

notifyComponentError

public void notifyComponentError()

notifyComponentErrorEnded

public void notifyComponentErrorEnded()