Modifier and Type | Field and Description |
---|---|
protected List<Instrument> |
AbstractChannel.AbstractInstrumentResolverAdaptor.instruments |
protected List<Instrument> |
AbstractChannel.InstrumentResolverAdaptor.instruments |
Modifier and Type | Method and Description |
---|---|
Instrument |
InstrumentStorage.getInstrumentBySecId(String secId) |
Instrument |
InstrumentStorage.getInstrumentBySymbol(String symbol) |
Modifier and Type | Method and Description |
---|---|
List<Instrument> |
InstrumentStorage.getInstrumentBySecGroup(String secGroup) |
List<Instrument> |
InstrumentStorage.getInstruments() |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentStorage.addInstrument(Instrument instrument) |
void |
StateHandler.handleState(Instrument instrument,
State state,
AbstractChannel abstractChannel) |
void |
StateProcessor.processNewState(Instrument inst,
State state) |
void |
StateProcessor.setState(Instrument inst,
State state) |
void |
MarketMessageSubscriber.subscribe(Instrument inst) |
void |
MarketMessageSubscriber.unsubscribe(Instrument instr) |
Modifier and Type | Method and Description |
---|---|
void |
ChannelContext.processNewState(Instrument instr,
State state) |
void |
ChannelContext.stopRecoveryFeed(Instrument instrument) |
Modifier and Type | Method and Description |
---|---|
void |
MarketDataSyncManager.startFeeds(Instrument instrument) |
void |
MarketDataSyncManager.stopFeeds(Instrument instrument) |
void |
MarketDataSyncManager.stopRecoveryFeed(Instrument instrument) |
Modifier and Type | Method and Description |
---|---|
void |
ForcedHistoricalRecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener replayListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
GlobalTCPHistoricalRecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener replayListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
HistoricalRecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener replayListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
NoneRecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener recoveryListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
RecoveryManager.startRecovery(Instrument instrument,
long beginMsgSeqNum,
long endMsgSeqNum,
ReplayListener recoveryListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
SnapshotRecoveryStreamManager.startRecovery(Instrument instrument,
long beginMsgSeqNum34,
long endMsgSeqNum34,
ReplayListener recoveryListener,
com.epam.fast.full.coders.stream.SeqNumHelper secNumHelper,
boolean forceSnapshotRecovery) |
void |
ForcedHistoricalRecoveryManager.stopRecovery(Instrument instrument) |
void |
GlobalTCPHistoricalRecoveryManager.stopRecovery(Instrument instrument) |
void |
HistoricalRecoveryManager.stopRecovery(Instrument instrument) |
void |
NoneRecoveryManager.stopRecovery(Instrument instrument) |
void |
RecoveryManager.stopRecovery(Instrument instrument) |
void |
SnapshotRecoveryStreamManager.stopRecovery(Instrument instrument) |
void |
ForcedHistoricalRecoveryManager.stopSnapshotRecovery(Instrument instrument) |
void |
GlobalTCPHistoricalRecoveryManager.stopSnapshotRecovery(Instrument instrument) |
void |
HistoricalRecoveryManager.stopSnapshotRecovery(Instrument instrument) |
Modifier and Type | Method and Description |
---|---|
protected boolean |
SnapshotMessageProcessor.processInternal(Instrument instrument,
FIXFieldList msg) |
protected boolean |
IncrementMessageProcessor.processInternal(Instrument instrument,
GroupEntry entry) |
protected abstract boolean |
AbstractInstrumentMessageProcessor.processInternal(Instrument instrument,
T msg) |
boolean |
AbstractInstrumentMessageProcessor.processMessage(Instrument instrument,
T msg) |
boolean |
InstrumentMessageProcessor.processMessage(Instrument instr,
T msg)
Process message.
|
Constructor and Description |
---|
RecoveryReplayListener(Instrument instrument,
RecoveryManager recoveryManager,
InstrumentListener instrumentListener) |
Modifier and Type | Method and Description |
---|---|
void |
DisconnectStateHandler.handleState(Instrument instrument,
State state,
AbstractChannel abstractChannel) |
void |
NormalStateHandler.handleState(Instrument instrument,
State state,
AbstractChannel abstractChannel) |
void |
RecoveryStateHandler.handleState(Instrument instrument,
State state,
AbstractChannel abstractChannel) |
void |
SynchronizeStateHandler.handleState(Instrument instrument,
State state,
AbstractChannel abstractChannel) |
Modifier and Type | Method and Description |
---|---|
Instrument |
InstrumentStorageImpl.getInstrumentBySecId(String secId) |
Instrument |
InstrumentStorageImpl.getInstrumentBySymbol(String symbol) |
Modifier and Type | Method and Description |
---|---|
List<Instrument> |
InstrumentStorageImpl.getInstrumentBySecGroup(String secGroup) |
List<Instrument> |
InstrumentStorageImpl.getInstruments() |
Modifier and Type | Method and Description |
---|---|
void |
InstrumentStorageImpl.addInstrument(Instrument instrument) |
Copyright © 2000-2017 EPAM Systems. All Rights Reserved.