Package | Description |
---|---|
com.epam.cmefast.impl | |
com.epam.cmefast.impl.recovery | |
com.epam.cmefast.impl.recovery.fix |
Modifier and Type | Field and Description |
---|---|
protected Map<String,List<Instrument>> |
ApplicationImpl.channelInstruments |
protected List<Instrument> |
ApplicationImpl.instruments |
protected Map<String,Instrument> |
ApplicationImpl.instrumentsBySecDesc |
protected Map<Long,Instrument> |
ApplicationImpl.instrumentsBySecID |
Modifier and Type | Method and Description |
---|---|
Instrument |
ChannelSubscriptionHelper.getFakeChannelInstrument(MDChannel channel) |
Instrument |
ApplicationContext.getInstrument(long longValue) |
Modifier and Type | Method and Description |
---|---|
List<Instrument> |
ApplicationContext.getChannelInstruments(String channelID) |
Modifier and Type | Method and Description |
---|---|
void |
MessageCorridorProcessor.continueCorridorProcessing(Instrument instrument) |
void |
ApplicationContext.disconnectAllByInstrument(Instrument instrument) |
void |
ApplicationContext.disconnectFromSnapshot(Instrument instrument,
boolean riseStopEvent,
RecoveryReason recoveryReason) |
void |
MessageProcessor.handleEvent(Instrument instrument,
InstrumentEvent event) |
void |
MessageProcessor.handleForcedRecovery(Instrument instrument,
ForcedRecoveryEvent event) |
void |
MessageProcessor.handleSnapshotReset(Instrument instrument,
SnapshotResetEvent event) |
void |
MessageCorridorProcessor.processEventInCorridor(Instrument instrument,
InstrumentEvent event) |
boolean |
MessageProcessor.processIncrement(Instrument instrument,
GroupEntry entry) |
void |
MessageCorridorProcessor.processIncrementInCorridor(Instrument instrument,
GroupEntry entry) |
void |
MessageCorridorProcessor.processOtherInCorridor(Instrument instrument,
FIXFieldList msg) |
void |
MessageProcessor.processSnapshot(Instrument instrument,
FIXFieldList msg) |
void |
MessageCorridorProcessor.processSnapshotInCorridor(Instrument instrument,
FIXFieldList msg) |
void |
ApplicationImpl.riseOnRecoveryStopped(Instrument instrument,
RecoveryReason recoveryReason) |
Modifier and Type | Method and Description |
---|---|
void |
HistoricalRecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum) |
void |
RecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum) |
void |
HistoricalRecoveryManager.stopRecovery(Instrument instrument) |
void |
RecoveryManager.stopRecovery(Instrument instrument) |
Modifier and Type | Method and Description |
---|---|
void |
ReplayRequestExecutor.queueRecoveryRequest(long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener replayListener,
com.epam.fast.full.coders.stream.SeqNumHelper seqNumHelper,
Instrument instrument) |
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.