public class IncrementMessageProcessor extends AbstractInstrumentMessageProcessor<GroupEntry>
log, MAX_DEFAULT_PACKETS_DELTA, messageListener, stateProcessor
Constructor and Description |
---|
IncrementMessageProcessor(InstrumentListener messageListener,
RecoveryManager recoveryManager,
StateProcessor stateProcessor,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
processInternal(Instrument instrument,
GroupEntry entry) |
processMessage
public IncrementMessageProcessor(InstrumentListener messageListener, RecoveryManager recoveryManager, StateProcessor stateProcessor, com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper)
protected boolean processInternal(Instrument instrument, GroupEntry entry)
processInternal
in class AbstractInstrumentMessageProcessor<GroupEntry>
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.