com.epam.bovespafast.impl.manager

Class MarketDataSyncManager

java.lang.Object

com.epam.bovespafast.impl.manager.MarketDataSyncManager

public class MarketDataSyncManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ChannelContext	context
protected com.epam.common.logging.Log	log
protected SnapshotManager	snapshotManager
protected TransportMessageSubscriber	transportMessageSubscriber

Constructor Summary

Constructors

Constructor and Description
MarketDataSyncManager(ChannelContext context)

Method Summary

Modifier and Type	Method and Description
void	startFeeds()
void	startFeeds(Instrument instrument)
void	startRecoveryFeed()
void	stopFeeds()
void	stopFeeds(Instrument instrument)
void	stopIncrementFeed()
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 final com.epam.common.logging.Log log

context

protected ChannelContext context

transportMessageSubscriber

protected TransportMessageSubscriber transportMessageSubscriber

snapshotManager

protected SnapshotManager snapshotManager

Constructor Detail

MarketDataSyncManager

public MarketDataSyncManager(ChannelContext context)

Method Detail

startFeeds

public void startFeeds()
                throws IOException

Throws:

IOException

stopRecoveryFeed

public void stopRecoveryFeed(Instrument instrument)
                      throws IOException

Throws:

IOException

startRecoveryFeed

public void startRecoveryFeed()
                       throws IOException

Throws:

IOException

stopFeeds

public void stopFeeds()
               throws IOException

Throws:

IOException

stopIncrementFeed

public void stopIncrementFeed()
                       throws IOException

Throws:

IOException

startFeeds

public void startFeeds(Instrument instrument)
                throws IOException

Throws:

IOException

stopFeeds

public void stopFeeds(Instrument instrument)
               throws IOException

Throws:

IOException