com.epam.cmefast.impl.recovery.fix

Class ReplayRequestExecutor

java.lang.Object

com.epam.cmefast.impl.recovery.fix.ReplayRequestExecutor

public class ReplayRequestExecutor
extends Object

Created by IntelliJ IDEA. User: Alexander_Sereda Date: 24.11.11 Time: 17:12 To change this template use File | Settings | File Templates.

Field Summary

Fields

Modifier and Type	Field and Description
boolean	enableSmartGapRequest
static int	FIX_RECOVERY_MAX_RQ_SIZE
int	intervalForCombine

Constructor Summary

Constructors

Constructor and Description
ReplayRequestExecutor(String channelId, FIXFastTransport transport, FASTDecoderFactory decoderFactory)

Method Summary

Methods

Modifier and Type	Method and Description
void	queueRecoveryRequest(long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener, com.epam.fast.full.coders.stream.SeqNumHelper seqNumHelper, Instrument instrument)
void	setEnableSmartGapRequest(boolean enableSmartGapRequest)
void	setIntervalForCombine(int intervalForCombine)
void	stop()

Methods inherited from class java.lang.Object

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

Field Detail

FIX_RECOVERY_MAX_RQ_SIZE

public static final int FIX_RECOVERY_MAX_RQ_SIZE

See Also:

Constant Field Values

enableSmartGapRequest

public boolean enableSmartGapRequest

intervalForCombine

public int intervalForCombine

Constructor Detail

ReplayRequestExecutor

public ReplayRequestExecutor(String channelId,
                     FIXFastTransport transport,
                     FASTDecoderFactory decoderFactory)

Method Detail

setEnableSmartGapRequest

public void setEnableSmartGapRequest(boolean enableSmartGapRequest)

setIntervalForCombine

public void setIntervalForCombine(int intervalForCombine)

queueRecoveryRequest

public void queueRecoveryRequest(long beginMsgSeqNum,
                        long endMsgSeqNum,
                        ReplayListener replayListener,
                        com.epam.fast.full.coders.stream.SeqNumHelper seqNumHelper,
                        Instrument instrument)

stop

public void stop()