com.epam.bovespafast.impl

Class AbstractChannel

java.lang.Object

com.epam.bovespafast.impl.AbstractChannel

All Implemented Interfaces:

Channel

Direct Known Subclasses:

ChannelImpl, ReplayChannelImpl

public abstract class AbstractChannel
extends Object
implements Channel

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	AbstractChannel.AbstractInstrumentResolverAdaptor
protected class	AbstractChannel.InstrumentResolverAdaptor
protected class	AbstractChannel.MDSubscriptionInstrumentResolverAdaptor

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelContext	context
protected MarketDataSyncManager	dataSyncManager
protected com.epam.bovespafast.impl.AbstractChannel.ErrorListenerWrapper	errorListener
protected com.epam.bovespafast.impl.AbstractChannel.InstrumentListenerWrapper	instrumentListener
protected InstrumentResolver	instrumentResolver
protected Log	log
protected MarketMessageSubscriber	marketMessageSubscriber
protected com.epam.bovespafast.impl.AbstractChannel.MessageListenerWrapper	messageListener
protected RecoveryManager	recoveryManager
protected StateProcessor	stateProcessor
protected TransportMessageSubscriber	transportMessageSubscriber

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractChannel(MDChannel mdChannel, RecoveryOptions recoveryOptions, FASTChannelFactory channelFactory, InstrumentStorageFactory instrumentStorageFactory)
	AbstractChannel(MDChannel mdChannel, RecoveryOptions recoveryOptions, FASTChannelFactory channelFactory, InstrumentStorageFactory instrumentStorageFactory, String interfaceName)
protected	AbstractChannel(MDChannel mdChannel, RecoveryOptions recoveryOptions, InputStream templateStream)
	AbstractChannel(MDChannel mdChannel, RecoveryOptions recoveryOptions, InputStream templateInputStream, String interfaceName)

Method Summary

Methods

Modifier and Type	Method and Description
void	findInstrumentBySecID(String secId, SecurityDefinitionListener securityDefinitionListener) Finds instrument in channel.
void	findInstrumentBySymbol(String symbol, SecurityDefinitionListener securityListener) Finds instrument in channel.
void	findInstruments(SecurityDefinitionListener securityDefinitionListener) Finds all instrument in channel.
MarketDataSyncManager	getDataSyncManager()
ErrorListener	getErrorListener()
InstrumentListener	getInstrumentListener()
int	getMaxCircleCount()
MessageListener	getMessageListener()
RecoveryManager	getRecoveryManager()
com.epam.fast.full.coders.stream.SeqNumHelper	getSecNumHelper()
StateProcessor	getStateProcessor()
TemplateContainer	getTemplateContainer()
protected TransportFactory	getTransportFactory(MDChannel mdChannel, FASTChannelFactory channelFactory, String interfaceName)
TransportMessageSubscriber	getTransportMessageSubscriber()
protected void	resetInstruments() Clear all known instruments
void	setErrorListener(ErrorListener errorListener) Sets error listener.
void	setInstrumentListener(InstrumentListener instrumentListener) Sets instrument listener.
void	setMessageListener(MessageListener messageListener) Sets message listener.
void	stop() Remove all subscription and close all opened connections.
void	subscribeAll() Subscribe for all instruments.
boolean	subscribeChannel(String channelID) Subscribe to instruments on channel.
void	subscribeSecGroup(String secGroup) Subscribe to instrument.
void	subscribeSecId(String secId) Subscribe to instrument.
void	subscribeSymbol(String symbol) Subscribe to instrument.
void	unSubscribeAll() UnSubscribe from instruments.
void	unSubscribeChannel(String channelID) Unsubscribe from instruments on channel.
void	unSubscribeSecGroup(String secGroup) UnSubscribe to instrument.
void	unSubscribeSecId(String secId) UnSubscribe to instrument.
void	unSubscribeSymbol(String symbol) UnSubscribe from instrument.

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final Log log

context

protected ChannelContext context

recoveryManager

protected RecoveryManager recoveryManager

instrumentResolver

protected InstrumentResolver instrumentResolver

stateProcessor

protected StateProcessor stateProcessor

dataSyncManager

protected MarketDataSyncManager dataSyncManager

marketMessageSubscriber

protected MarketMessageSubscriber marketMessageSubscriber

transportMessageSubscriber

protected TransportMessageSubscriber transportMessageSubscriber

instrumentListener

protected com.epam.bovespafast.impl.AbstractChannel.InstrumentListenerWrapper instrumentListener

messageListener

protected com.epam.bovespafast.impl.AbstractChannel.MessageListenerWrapper messageListener

errorListener

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

Constructor Detail

AbstractChannel

protected AbstractChannel(MDChannel mdChannel,
               RecoveryOptions recoveryOptions,
               InputStream templateStream)

AbstractChannel

protected AbstractChannel(MDChannel mdChannel,
               RecoveryOptions recoveryOptions,
               FASTChannelFactory channelFactory,
               InstrumentStorageFactory instrumentStorageFactory)

AbstractChannel

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

AbstractChannel

public AbstractChannel(MDChannel mdChannel,
               RecoveryOptions recoveryOptions,
               FASTChannelFactory channelFactory,
               InstrumentStorageFactory instrumentStorageFactory,
               String interfaceName)

Method Detail

getTransportFactory

protected TransportFactory getTransportFactory(MDChannel mdChannel,
                                   FASTChannelFactory channelFactory,
                                   String interfaceName)

getStateProcessor

public StateProcessor getStateProcessor()

getTransportMessageSubscriber

public TransportMessageSubscriber getTransportMessageSubscriber()

setInstrumentListener

public void setInstrumentListener(InstrumentListener instrumentListener)

Description copied from interface: Channel

Sets instrument listener.

Specified by:

setInstrumentListener in interface Channel

Parameters:

instrumentListener - the instrument listener

getInstrumentListener

public InstrumentListener getInstrumentListener()

getMessageListener

public MessageListener getMessageListener()

getErrorListener

public ErrorListener getErrorListener()

setMessageListener

public void setMessageListener(MessageListener messageListener)

Description copied from interface: Channel

Sets message listener.

Specified by:

setMessageListener in interface Channel

Parameters:

messageListener - the message listener

setErrorListener

public void setErrorListener(ErrorListener errorListener)

Description copied from interface: Channel

Sets error listener.

Specified by:

setErrorListener in interface Channel

Parameters:

errorListener - the error listener

getRecoveryManager

public RecoveryManager getRecoveryManager()

getDataSyncManager

public MarketDataSyncManager getDataSyncManager()

subscribeAll

public void subscribeAll()
                  throws IOException

Description copied from interface: Channel

Subscribe for all instruments.

Specified by:

subscribeAll in interface Channel

Throws:

IOException - - if error occurred

unSubscribeAll

public void unSubscribeAll()
                    throws IOException

Description copied from interface: Channel

UnSubscribe from instruments.

Specified by:

unSubscribeAll in interface Channel

Throws:

IOException - - if error occurred

subscribeSymbol

public void subscribeSymbol(String symbol)
                     throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSymbol in interface Channel

Parameters:

symbol - the symbol

Throws:

IOException - - if error occurred

unSubscribeSymbol

public void unSubscribeSymbol(String symbol)

Description copied from interface: Channel

UnSubscribe from instrument.

Specified by:

unSubscribeSymbol in interface Channel

Parameters:

symbol - the symbol

subscribeSecId

public void subscribeSecId(String secId)
                    throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSecId in interface Channel

Parameters:

secId - the security ID

Throws:

IOException - - if error occurred

unSubscribeSecId

public void unSubscribeSecId(String secId)

Description copied from interface: Channel

UnSubscribe to instrument.

Specified by:

unSubscribeSecId in interface Channel

Parameters:

secId - the security ID

subscribeSecGroup

public void subscribeSecGroup(String secGroup)
                       throws IOException

Description copied from interface: Channel

Subscribe to instrument.

Specified by:

subscribeSecGroup in interface Channel

Parameters:

secGroup - the security group

Throws:

IOException - - if error occurred

unSubscribeSecGroup

public void unSubscribeSecGroup(String secGroup)

Description copied from interface: Channel

UnSubscribe to instrument.

Specified by:

unSubscribeSecGroup in interface Channel

Parameters:

secGroup - the security group

findInstruments

public void findInstruments(SecurityDefinitionListener securityDefinitionListener)
                     throws IOException

Description copied from interface: Channel

Finds all instrument in channel.

Specified by:

findInstruments in interface Channel

Parameters:

securityDefinitionListener - the callback listener.

Throws:

IOException - - if error occurred

findInstrumentBySymbol

public void findInstrumentBySymbol(String symbol,
                          SecurityDefinitionListener securityListener)
                            throws IOException

Description copied from interface: Channel

Finds instrument in channel.

Specified by:

findInstrumentBySymbol in interface Channel

Parameters:

symbol - the symbol

securityListener - the listener

Throws:

IOException - - if error occurred

findInstrumentBySecID

public void findInstrumentBySecID(String secId,
                         SecurityDefinitionListener securityDefinitionListener)
                           throws IOException

Description copied from interface: Channel

Finds instrument in channel.

Specified by:

findInstrumentBySecID in interface Channel

Parameters:

secId - the security Id

securityDefinitionListener - the listener

Throws:

IOException - - if error occurred

subscribeChannel

public boolean subscribeChannel(String channelID)

Description copied from interface: Channel

Subscribe to instruments on channel.

Specified by:

subscribeChannel in interface Channel

Parameters:

channelID - unique id of channel

unSubscribeChannel

public void unSubscribeChannel(String channelID)

Description copied from interface: Channel

Unsubscribe from instruments on channel.

Specified by:

unSubscribeChannel in interface Channel

Parameters:

channelID - unique id of channel

stop

public void stop()
          throws IOException

Remove all subscription and close all opened connections.

Specified by:

stop in interface Channel

Throws:

IOException - - if error occurred

resetInstruments

protected void resetInstruments()

Clear all known instruments

getTemplateContainer

public TemplateContainer getTemplateContainer()

getSecNumHelper

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

getMaxCircleCount

public int getMaxCircleCount()