public class FIXReplayManager extends Object implements TransportStateListener
Modifier and Type | Field and Description |
---|---|
protected RequestRegistry |
requestRegistry |
protected AtomicBoolean |
started |
Constructor and Description |
---|
FIXReplayManager(TransportMessageSubscriber transportMessageSubscriber) |
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() |
protected AtomicBoolean started
protected RequestRegistry requestRegistry
public FIXReplayManager(TransportMessageSubscriber transportMessageSubscriber)
public void replayMessages(Request request)
public void dispose()
protected FIXTransport getTransportImpl()
public void stopReplays()
public void setFASTDecoderFactory(FASTDecoderFactory decoderFactory)
public void onConnected()
onConnected
in interface TransportStateListener
public void onDisconnect()
onDisconnect
in interface TransportStateListener
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.