166 const std::string& source_;
167 const std::string& description_;
#define ONIXS_CMEMDH_NAMESPACE_BEGIN
#define ONIXS_CMEMDH_LTWT
#define ONIXS_CMEMDH_EXPORTED_CLASS_DECL(typeName)
#define ONIXS_CMEMDH_NAMESPACE_END
#define ONIXS_CMEMDH_EXPORTED
Encapsulates all the machinery related with market data processing from CME Market Data Platform.
Gathers information about the issue Handler may experience while processing market data.
Issue::Enum id() const
Issue identifier.
IssueArgs(Issue::Enum id, const std::string &source, const std::string &description)
Initializes issue with provided attributes.
const std::string & source() const
Source of the issue.
const std::string & description() const
Human readable description of the issue.
Gathers information about the recovery completion.
RecoveryCompletionArgs(RecoveryCompletionStatus::Enum status, const std::string &message=std::string())
Initializes with given details.
const std::string & details() const
Human readable description of recovery completion.
void details(const std::string &message)
Associates human readable message with recover completion event.
RecoveryCompletionArgs()
Initializes as blank instance.
RecoveryCompletionStatus::Enum status() const
Indicates completion status of the recovery.
IssueArgs ErrorArgs
Error arguments.
IssueArgs WarningArgs
Warning arguments.
std::ostream & operator<<(std::ostream &stream, const IssueArgs &args)
Events raised by Handler while processing market data.
virtual void onStopped(Handler &)
Invoked when Handler has stopped market data processing.
virtual void onStarted(Handler &)
Handler is has started to process market data.
virtual void onEndOfInstrumentRecovery(Handler &, const RecoveryCompletionArgs &)
Download or replay of Security Definition(d) messages is finished.
virtual void onError(Handler &, const ErrorArgs &)
Error occurred while Handler is processing market data.
virtual void onTcpRecovery(Handler &)
Handler spawned recovery of lost packets over TCP feed.
virtual void onEndOfTcpRecovery(Handler &, const RecoveryCompletionArgs &)
Handler accomplished recovery of lost packets over TCP feed.
virtual void onMarketRecovery(Handler &)
Handler started recovering order books from snapshots.
virtual void onInstrumentRecovery(Handler &)
Download or replay of Security Definition(d) messages is started.
virtual void onEndOfRealtimeProcessing(Handler &)
Handler suspended real-time processing of market data received over incremental feeds.
virtual void onWarning(Handler &, const WarningArgs &)
Non-critical issue occurred while Handler is processing market data.
virtual void onEndOfMarketRecovery(Handler &, const RecoveryCompletionArgs &)
Handler accomplished recovering order books from snapshots.
virtual void onRealtimeProcessing(Handler &)
Handler resumed real-time processing of market data received over incremental feeds.
Collection of issues Handler may report during market data processing.
@ ConnectionFailure
Identifies network connection failure.
@ ProcessingFailure
Indicates data processing failure.
@ ReceiveTimeout
Indicates data receive timeout.
@ ReducedCapacity
Source reported this issue will function in reduced capacity.
@ QueueOverflow
Indicates internal queue overflow.
@ OperationFailure
Operation performed by the Handler failed.
@ ReplayFailure
Market data replay failed.
@ OperationTimeout
Operation performed by the Handler did not accomplish within the time allocated for it.
@ ReceiveFailure
Indicates data reception failure.
@ SequenceError
Indicates error in data sequence.
Collection of statuses of recovery completion.
@ Failed
Recovery failed and no further attempts to recover will be made.
@ Incomplete
Identifies incomplete recovery.
@ Succeeded
Recovery accomplished successfully.