com.epam.bovespafast.impl.manager.recovery.fix

Class FIXReplayManager

java.lang.Object

com.epam.bovespafast.impl.manager.recovery.fix.FIXReplayManager

All Implemented Interfaces:

TransportStateListener

public class FIXReplayManager
extends Object
implements TransportStateListener

Field Summary

Fields

Modifier and Type	Field and Description
protected RequestRegistry	requestRegistry
protected AtomicBoolean	started

Constructor Summary

Constructors

Constructor and Description
FIXReplayManager(TransportMessageSubscriber transportMessageSubscriber)

Method Summary

Modifier and Type	Method and Description
void	dispose()
protected FIXTransport	getTransportImpl()
void	onConnected()
void	onDisconnect()
void	replayMessages(Request request)
void	setFASTDecoderFactory(FASTDecoderFactory decoderFactory)
void	stopReplays()

Methods inherited from class java.lang.Object

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

Field Detail

started

protected AtomicBoolean started

requestRegistry

protected RequestRegistry requestRegistry

Constructor Detail

FIXReplayManager

public FIXReplayManager(TransportMessageSubscriber transportMessageSubscriber)

Method Detail

replayMessages

public void replayMessages(Request request)

dispose

public void dispose()

getTransportImpl

protected FIXTransport getTransportImpl()

stopReplays

public void stopReplays()

setFASTDecoderFactory

public void setFASTDecoderFactory(FASTDecoderFactory decoderFactory)

onConnected

public void onConnected()

Specified by:

onConnected in interface TransportStateListener

onDisconnect

public void onDisconnect()

Specified by:

onDisconnect in interface TransportStateListener