com.epam.bovespafast.impl

Class ReplayChannelImpl

java.lang.Object

com.epam.bovespafast.impl.AbstractChannel

com.epam.bovespafast.impl.ReplayChannelImpl

All Implemented Interfaces:

ReplayChannel, Channel

public class ReplayChannelImpl
extends AbstractChannel
implements ReplayChannel

Created by IntelliJ IDEA. User: Alexander_Lukashevich Date: Oct 24, 2013

Nested Class Summary

Nested classes/interfaces inherited from class com.epam.bovespafast.impl.AbstractChannel

AbstractChannel.AbstractInstrumentResolverAdaptor, AbstractChannel.InstrumentResolverAdaptor, AbstractChannel.MDSubscriptionInstrumentResolverAdaptor

Field Summary

Fields

Modifier and Type	Field and Description
protected com.epam.bovespafast.impl.ReplayChannelImpl.ErrorListenerWrapper	errorListener
protected com.epam.common.logging.Log	log

Fields inherited from class com.epam.bovespafast.impl.AbstractChannel

context, dataSyncManager, instrumentListener, instrumentResolver, marketMessageSubscriber, messageListener, recoveryManager, stateProcessor, transportMessageSubscriber

Constructor Summary

Constructors

Constructor and Description
ReplayChannelImpl(MDChannel mdChannel, RecoveryOptions recoveryOptions, InputStream templateInputStream, String interfaceName)

Method Summary

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.

Methods inherited from class com.epam.bovespafast.impl.AbstractChannel

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

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.api.ReplayChannel

setErrorListener, setInstrumentListener, subscribeAll, subscribeSymbol, unSubscribeAll

Field Detail

log

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

errorListener

protected com.epam.bovespafast.impl.ReplayChannelImpl.ErrorListenerWrapper errorListener

Constructor Detail

ReplayChannelImpl

public ReplayChannelImpl(MDChannel mdChannel,
                         RecoveryOptions recoveryOptions,
                         InputStream templateInputStream,
                         String interfaceName)

Method Detail

subscribeSecId

public void subscribeSecId(String secId,
                           long start,
                           long end)
                    throws IOException

Description copied from interface: ReplayChannel

Subscribe to instrument to get messages from the specified range.

Specified by:

subscribeSecId in interface ReplayChannel

Parameters:

secId - the security ID

start - the recover start number

end - the recovery end number

Throws:

IOException - - if error occurred

subscribeSymbol

public void subscribeSymbol(String symbol,
                            long start,
                            long end)
                     throws IOException

Description copied from interface: ReplayChannel

Subscribe to instrument to get messages from the specified range.

Specified by:

subscribeSymbol in interface ReplayChannel

Parameters:

symbol - the symbol parameter value

start - the recover start number

end - the recovery end number

Throws:

IOException - - if error occurred