public class ReplayChannelImpl extends AbstractChannel implements ReplayChannel
AbstractChannel.AbstractInstrumentResolverAdaptor, AbstractChannel.InstrumentResolverAdaptor, AbstractChannel.MDSubscriptionInstrumentResolverAdaptor
Modifier and Type | Field and Description |
---|---|
protected com.epam.bovespafast.impl.ReplayChannelImpl.ErrorListenerWrapper |
errorListener |
protected Log |
log |
context, dataSyncManager, instrumentListener, instrumentResolver, marketMessageSubscriber, messageListener, recoveryManager, stateProcessor, transportMessageSubscriber
Constructor and Description |
---|
ReplayChannelImpl(MDChannel mdChannel,
RecoveryOptions recoveryOptions,
InputStream templateInputStream,
String interfaceName) |
Modifier and Type | Method and Description |
---|---|
void |
subscribeSecId(String secId,
long start,
long end)
Subscribe to instrument to get messages from the specified range.
|
void |
subscribeSymbol(String symbol,
long start,
long end)
Subscribe to instrument to get messages from the specified range.
|
findInstrumentBySecID, findInstrumentBySymbol, findInstruments, getDataSyncManager, getErrorListener, getInstrumentListener, getMaxCircleCount, getMessageListener, getRecoveryManager, getSecNumHelper, getStateProcessor, getTemplateContainer, getTransportFactory, getTransportMessageSubscriber, resetInstruments, setErrorListener, setInstrumentListener, setMessageListener, stop, subscribeAll, subscribeChannel, subscribeSecGroup, subscribeSecId, subscribeSymbol, unSubscribeAll, unSubscribeChannel, unSubscribeSecGroup, unSubscribeSecId, unSubscribeSymbol
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
setErrorListener, setInstrumentListener, subscribeAll, subscribeSymbol, unSubscribeAll
protected final Log log
protected com.epam.bovespafast.impl.ReplayChannelImpl.ErrorListenerWrapper errorListener
public ReplayChannelImpl(MDChannel mdChannel, RecoveryOptions recoveryOptions, InputStream templateInputStream, String interfaceName)
public void subscribeSecId(String secId, long start, long end) throws IOException
ReplayChannel
subscribeSecId
in interface ReplayChannel
secId
- the security IDstart
- the recover start numberend
- the recovery end numberIOException
- - if error occurredpublic void subscribeSymbol(String symbol, long start, long end) throws IOException
ReplayChannel
subscribeSymbol
in interface ReplayChannel
symbol
- the symbol parameter valuestart
- the recover start numberend
- the recovery end numberIOException
- - if error occurredCopyright © 2000-2017 EPAM Systems. All Rights Reserved.