com.epam.cmemdp.impl.recovery.fix
Class ReplayRequestExecutor

java.lang.Object
  com.epam.cmemdp.impl.recovery.fix.ReplayRequestExecutor

public class ReplayRequestExecutor
extends java.lang.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

boolean	enableSmartGapRequest
static int	FIX_RECOVERY_MAX_RQ_SIZE
int	intervalForCombine

Constructor Summary

ReplayRequestExecutor(java.lang.String channelId, FIXFastTransport transport, FASTDecoderFactory decoderFactory)

Method Summary

void	queueRecoveryRequest(long beginMsgSeqNum, long endMsgSeqNum, ReplayListener replayListener, com.epam.mdp.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(java.lang.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.mdp.full.coders.stream.SeqNumHelper seqNumHelper,
                                 Instrument instrument)

stop

public void stop()