public class ChannelContext extends Object
Modifier and Type | Field and Description |
---|---|
protected static Log |
LOG |
protected RecoveryOptions |
recoveryOptions |
Constructor and Description |
---|
ChannelContext(AbstractChannel abstractChannel) |
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) |
protected static final Log LOG
protected RecoveryOptions recoveryOptions
public ChannelContext(AbstractChannel abstractChannel)
public RecoveryOptions getRecoveryOptions()
public void setRecoveryOptions(RecoveryOptions recoveryOptions)
public InstrumentStorage getInstrumentStorage()
public void setInstrumentStorage(InstrumentStorage instrumentStorage)
public MessageChopper getMessageChopper()
public void setMessageChopper(MessageChopper messageChopper)
public String getChannelId()
public void setChannelId(String channelId)
public void startRecoveryFeed() throws IOException
IOException
public void processNewState(Instrument instr, State state)
public void stopRecoveryFeed(Instrument instrument) throws IOException
IOException
public void stopFeeds() throws IOException
IOException
public InstrumentListener getInstrumentListener()
public StateProcessor getStateProcessor()
public RecoveryManager getRecoveryManager()
public MessageListener getMessageListener()
public TransportMessageSubscriber getTransportMessageSubscriber()
public void setChannelFactory(FASTChannelFactory channelFactory)
public FASTChannelFactory getChannelFactory()
public com.epam.fast.full.coders.stream.SeqNumHelper getSecNumHelper()
public AbstractChannel getChannel()
public void notifyComponentError()
public void notifyComponentErrorEnded()
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.