OnixS C++ B3 Binary UMDF Market Data Handler 1.10.0
Users' manual and API documentation
Loading...
Searching...
No Matches
MessageListener.h
Go to the documentation of this file.
1/*
2* Copyright Onix Solutions Limited [OnixS]. All rights reserved.
3*
4* This software owned by Onix Solutions Limited [OnixS] and is protected by copyright law
5* and international copyright treaties.
6*
7* Access to and use of the software is governed by the terms of the applicable ONIXS Software
8* Services Agreement (the Agreement) and Customer end user license agreements granting
9* a non-assignable, non-transferable and non-exclusive license to use the software
10* for it's own data processing purposes under the terms defined in the Agreement.
11*
12* Except as otherwise granted within the terms of the Agreement, copying or reproduction of any part
13* of this source code or associated reference material to any other location for further reproduction
14* or redistribution, and any amendments to this copyright notice, are expressly prohibited.
15*
16* Any reproduction or redistribution for sale or hiring of the Software not in accordance with
17* the terms of the Agreement is a violation of copyright law.
18*/
19
20#pragma once
21
24#include <OnixS/B3/MarketData/UMDF/Utils.h>
25
27
28ONIXS_B3_UMDF_MD_API_DECL(class, SecurityContext);
29ONIXS_B3_UMDF_MD_API_DECL(struct, DataSource);
30
32class ONIXS_B3_UMDF_MD_API MessageListener
33{
34public:
38 virtual void onSequenceReset_1(const Messaging::SequenceReset_1 msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
39
40
43 virtual void onSequence_2(const Messaging::Sequence_2 msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
44
49 virtual void onEmptyBook_9(const Messaging::EmptyBook_9 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
50
54 virtual void onChannelReset_11(const Messaging::ChannelReset_11 msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
55
60 virtual void onSecurityStatus_3(const Messaging::SecurityStatus_3 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
61
65 virtual void onSecurityGroupPhase_10(const Messaging::SecurityGroupPhase_10 msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
66
71 virtual void onSecurityDefinition_12(const Messaging::SecurityDefinition_12 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
72
77 virtual void onSnapshotFullRefresh_Header_30(const Messaging::SnapshotFullRefresh_Header_30 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
78
83 virtual void onSnapshotFullRefresh_Orders_MBO_71(const Messaging::SnapshotFullRefresh_Orders_MBO_71 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
84
88 virtual void onNews_5(const Messaging::News_5 msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
89
94 virtual void onClosingPrice_17(const Messaging::ClosingPrice_17 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
95
100 virtual void onQuantityBand_21(const Messaging::QuantityBand_21 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
101
106 virtual void onPriceBand_22(const Messaging::PriceBand_22 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
107
112 virtual void onOpeningPrice_15(const Messaging::OpeningPrice_15 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
113
118 virtual void onTheoreticalOpeningPrice_16(const Messaging::TheoreticalOpeningPrice_16 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
119
124 virtual void onAuctionImbalance_19(const Messaging::AuctionImbalance_19 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
125
130 virtual void onHighPrice_24(const Messaging::HighPrice_24 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
131
136 virtual void onLowPrice_25(const Messaging::LowPrice_25 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
137
142 virtual void onLastTradePrice_27(const Messaging::LastTradePrice_27 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
143
148 virtual void onSettlementPrice_28(const Messaging::SettlementPrice_28 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
149
154 virtual void onOpenInterest_29(const Messaging::OpenInterest_29 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
155
160 virtual void onOrder_MBO_50(const Messaging::Order_MBO_50 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
161
166 virtual void onDeleteOrder_MBO_51(const Messaging::DeleteOrder_MBO_51 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
167
174 virtual void onMassDeleteOrders_MBO_52(const Messaging::MassDeleteOrders_MBO_52 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
175
180 virtual void onTrade_53(const Messaging::Trade_53 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
181
186 virtual void onForwardTrade_54(const Messaging::ForwardTrade_54 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
187
192 virtual void onExecutionSummary_55(const Messaging::ExecutionSummary_55 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
193
198 virtual void onExecutionStatistics_56(const Messaging::ExecutionStatistics_56 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
199
202 virtual void onTradeBust_57(const Messaging::TradeBust_57 msg, const DataSource& ds, SecurityContext& ctx) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds, ctx)
203
207 virtual void onUnknownMessage(const Messaging::SbeMessage msg, const DataSource& ds) ONIXS_B3_UMDF_MD_EMPTY_BODY(msg, ds)
208
210 virtual void onInstrumentChannelGap() ONIXS_B3_UMDF_MD_EMPTY_BODY();
211
213 virtual void onInstrumentChannelInactivity() ONIXS_B3_UMDF_MD_EMPTY_BODY()
214
216 virtual void onInstrumentRecoveryStarted() ONIXS_B3_UMDF_MD_EMPTY_BODY()
217
219 virtual void onInstrumentRecoveryFinished() ONIXS_B3_UMDF_MD_EMPTY_BODY()
220
222 virtual void onSnapshotChannelGap() ONIXS_B3_UMDF_MD_EMPTY_BODY()
223
225 virtual void onSnapshotChannelInactivity() ONIXS_B3_UMDF_MD_EMPTY_BODY()
226
228 virtual void onSnapshotRecoveryStarted() ONIXS_B3_UMDF_MD_EMPTY_BODY()
229
231 virtual void onSnapshotRecoveryFinished() ONIXS_B3_UMDF_MD_EMPTY_BODY()
232
234 virtual void onIncrementalChannelGap() ONIXS_B3_UMDF_MD_EMPTY_BODY()
235
237 virtual void onIncrementalChannelInactivity() ONIXS_B3_UMDF_MD_EMPTY_BODY()
238
240 virtual void onInstrumentSequenceGap(Messaging::SecurityID) ONIXS_B3_UMDF_MD_EMPTY_BODY()
241
242protected:
243 virtual ~MessageListener() = 0;
244};
245
#define ONIXS_B3_UMDF_MD_NAMESPACE_END
Definition ABI.h:168
#define ONIXS_B3_UMDF_MD_NAMESPACE_BEGIN
Definition ABI.h:163
#define ONIXS_B3_UMDF_MD_API_DECL(typeKind, typeName)
Definition ABI.h:31
virtual void onMassDeleteOrders_MBO_52(const Messaging::MassDeleteOrders_MBO_52 msg, const DataSource &ds, SecurityContext &ctx)
Is called when MassDeleteOrders_MBO_52 message is received.
virtual void onInstrumentSequenceGap(Messaging::SecurityID)
Is called when an instrument seqence gap is detected.
virtual void onSequence_2(const Messaging::Sequence_2 msg, const DataSource &ds)
Is called when Sequence_2 message is received.
virtual void onEmptyBook_9(const Messaging::EmptyBook_9 msg, const DataSource &ds, SecurityContext &ctx)
Is called when EmptyBook_9 message is received.
virtual void onClosingPrice_17(const Messaging::ClosingPrice_17 msg, const DataSource &ds, SecurityContext &ctx)
Is called when ClosingPrice_17 message is received.
virtual void onExecutionStatistics_56(const Messaging::ExecutionStatistics_56 msg, const DataSource &ds, SecurityContext &ctx)
Is called when ExecutionStatistics_56 message is received.
virtual void onInstrumentRecoveryFinished()
Is called when instrument recovery process has finished.
virtual void onPriceBand_22(const Messaging::PriceBand_22 msg, const DataSource &ds, SecurityContext &ctx)
Is called when PriceBand_22 message is received.
virtual void onSecurityDefinition_12(const Messaging::SecurityDefinition_12 msg, const DataSource &ds, SecurityContext &ctx)
Is called when SecurityDefinition_12 message is received.
virtual void onInstrumentChannelGap()
Is called when an instrument channel sequence gap is detected.
virtual void onSettlementPrice_28(const Messaging::SettlementPrice_28 msg, const DataSource &ds, SecurityContext &ctx)
Is called when SettlementPrice_28 message is received.
virtual void onInstrumentRecoveryStarted()
Is called when instrument recovery process has started.
virtual void onOpenInterest_29(const Messaging::OpenInterest_29 msg, const DataSource &ds, SecurityContext &ctx)
Is called when OpenInterest_29 message is received.
virtual void onSnapshotChannelInactivity()
Is called when a snapshot channel inactivity timeout is detected.
virtual void onSnapshotChannelGap()
Is called when a snapshot channel sequence gap is detected.
virtual void onInstrumentChannelInactivity()
Is called when an instrument channel inactivity timeout is detected.
virtual void onHighPrice_24(const Messaging::HighPrice_24 msg, const DataSource &ds, SecurityContext &ctx)
Is called when HighPrice_24 message is received.
virtual void onOrder_MBO_50(const Messaging::Order_MBO_50 msg, const DataSource &ds, SecurityContext &ctx)
Is called when Order_MBO_50 message is received.
virtual void onTheoreticalOpeningPrice_16(const Messaging::TheoreticalOpeningPrice_16 msg, const DataSource &ds, SecurityContext &ctx)
Is called when TheoreticalOpeningPrice_16 message is received.
virtual void onIncrementalChannelGap()
Is called when an incremental channel sequence gap is detected.
virtual void onSequenceReset_1(const Messaging::SequenceReset_1 msg, const DataSource &ds)
Is called when SequenceReset_1 message is received.
virtual void onTrade_53(const Messaging::Trade_53 msg, const DataSource &ds, SecurityContext &ctx)
Is called when Trade_53 message is received.
virtual void onLastTradePrice_27(const Messaging::LastTradePrice_27 msg, const DataSource &ds, SecurityContext &ctx)
Is called when LastTradePrice_27 message is received.
virtual void onChannelReset_11(const Messaging::ChannelReset_11 msg, const DataSource &ds)
Is called when ChannelReset_11 message is received.
virtual void onDeleteOrder_MBO_51(const Messaging::DeleteOrder_MBO_51 msg, const DataSource &ds, SecurityContext &ctx)
Is called when DeleteOrder_MBO_51 message is received.
virtual void onUnknownMessage(const Messaging::SbeMessage msg, const DataSource &ds)
Is called when an unknown/unsupported SBE message is received.
virtual void onSnapshotFullRefresh_Header_30(const Messaging::SnapshotFullRefresh_Header_30 msg, const DataSource &ds, SecurityContext &ctx)
Is called when SnapshotFullRefresh_Header_30 message is received.
virtual void onIncrementalChannelInactivity()
Is called when an incremental channel inactivity timeout is detected.
virtual void onQuantityBand_21(const Messaging::QuantityBand_21 msg, const DataSource &ds, SecurityContext &ctx)
Is called when QuantityBand_21 message is received.
virtual void onSnapshotFullRefresh_Orders_MBO_71(const Messaging::SnapshotFullRefresh_Orders_MBO_71 msg, const DataSource &ds, SecurityContext &ctx)
Is called when SnapshotFullRefresh_Orders_MBO_71 message is received.
virtual void onSecurityStatus_3(const Messaging::SecurityStatus_3 msg, const DataSource &ds, SecurityContext &ctx)
Is called when SecurityStatus_3 message is received.
virtual void onTradeBust_57(const Messaging::TradeBust_57 msg, const DataSource &ds, SecurityContext &ctx)
virtual void onOpeningPrice_15(const Messaging::OpeningPrice_15 msg, const DataSource &ds, SecurityContext &ctx)
Is called when OpeningPrice_15 message is received.
virtual void onSnapshotRecoveryFinished()
Is called when snapshot recovery process has finished.
virtual void onExecutionSummary_55(const Messaging::ExecutionSummary_55 msg, const DataSource &ds, SecurityContext &ctx)
Is called when ExecutionSummary_55 message is received.
virtual void onLowPrice_25(const Messaging::LowPrice_25 msg, const DataSource &ds, SecurityContext &ctx)
Is called when LowPrice_25 message is received.
virtual void onNews_5(const Messaging::News_5 msg, const DataSource &ds)
Is called when News_5 message is received.
virtual void onForwardTrade_54(const Messaging::ForwardTrade_54 msg, const DataSource &ds, SecurityContext &ctx)
Is called when ForwardTrade_54 message is received.
virtual void onSnapshotRecoveryStarted()
Is called when snapshot recovery process has started.
virtual void onAuctionImbalance_19(const Messaging::AuctionImbalance_19 msg, const DataSource &ds, SecurityContext &ctx)
Is called when AuctionImbalance_19 message is received.
virtual void onSecurityGroupPhase_10(const Messaging::SecurityGroupPhase_10 msg, const DataSource &ds)
Is called when SecurityGroupPhase_10 message is received.
Used to reset the incremental stream or indicate the loop on instrument definition or snapshot recove...
Definition Messages.h:41