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) |
processMessagepublic 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–2025 EPAM Systems. All rights reserved.