quickfix-tokio 0.2.0

A pure-Rust FIX protocol engine built natively on tokio
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
205
206
207
208
209
210

//! GENERATED by `generate-fix` — do not edit by hand.
#![allow(clippy::all, unused_imports, unused_mut, dead_code, non_upper_case_globals)]

//! Typed messages for FIX.5.0 — generated from its spec XML.

pub mod fields;
pub mod messages;
pub use messages::*;

pub const BEGIN_STRING: &str = "FIX.5.0";

/// Every message type of this FIX version, for typed dispatch.
#[derive(Debug, Clone)]
pub enum AnyMessage {
    AdjustedPositionReport(messages::adjusted_position_report::AdjustedPositionReport),
    Advertisement(messages::advertisement::Advertisement),
    AllocationInstruction(messages::allocation_instruction::AllocationInstruction),
    AllocationInstructionAck(messages::allocation_instruction_ack::AllocationInstructionAck),
    AllocationInstructionAlert(messages::allocation_instruction_alert::AllocationInstructionAlert),
    AllocationReport(messages::allocation_report::AllocationReport),
    AllocationReportAck(messages::allocation_report_ack::AllocationReportAck),
    AssignmentReport(messages::assignment_report::AssignmentReport),
    BidRequest(messages::bid_request::BidRequest),
    BidResponse(messages::bid_response::BidResponse),
    BusinessMessageReject(messages::business_message_reject::BusinessMessageReject),
    CollateralAssignment(messages::collateral_assignment::CollateralAssignment),
    CollateralInquiry(messages::collateral_inquiry::CollateralInquiry),
    CollateralInquiryAck(messages::collateral_inquiry_ack::CollateralInquiryAck),
    CollateralReport(messages::collateral_report::CollateralReport),
    CollateralRequest(messages::collateral_request::CollateralRequest),
    CollateralResponse(messages::collateral_response::CollateralResponse),
    Confirmation(messages::confirmation::Confirmation),
    ConfirmationAck(messages::confirmation_ack::ConfirmationAck),
    ConfirmationRequest(messages::confirmation_request::ConfirmationRequest),
    ContraryIntentionReport(messages::contrary_intention_report::ContraryIntentionReport),
    CrossOrderCancelReplaceRequest(messages::cross_order_cancel_replace_request::CrossOrderCancelReplaceRequest),
    CrossOrderCancelRequest(messages::cross_order_cancel_request::CrossOrderCancelRequest),
    DerivativeSecurityList(messages::derivative_security_list::DerivativeSecurityList),
    DerivativeSecurityListRequest(messages::derivative_security_list_request::DerivativeSecurityListRequest),
    DontKnowTrade(messages::dont_know_trade::DontKnowTrade),
    Email(messages::email::Email),
    ExecutionAcknowledgement(messages::execution_acknowledgement::ExecutionAcknowledgement),
    ExecutionReport(messages::execution_report::ExecutionReport),
    IOI(messages::ioi::IOI),
    ListCancelRequest(messages::list_cancel_request::ListCancelRequest),
    ListExecute(messages::list_execute::ListExecute),
    ListStatus(messages::list_status::ListStatus),
    ListStatusRequest(messages::list_status_request::ListStatusRequest),
    ListStrikePrice(messages::list_strike_price::ListStrikePrice),
    MarketDataIncrementalRefresh(messages::market_data_incremental_refresh::MarketDataIncrementalRefresh),
    MarketDataRequest(messages::market_data_request::MarketDataRequest),
    MarketDataRequestReject(messages::market_data_request_reject::MarketDataRequestReject),
    MarketDataSnapshotFullRefresh(messages::market_data_snapshot_full_refresh::MarketDataSnapshotFullRefresh),
    MassQuote(messages::mass_quote::MassQuote),
    MassQuoteAcknowledgement(messages::mass_quote_acknowledgement::MassQuoteAcknowledgement),
    MultilegOrderCancelReplace(messages::multileg_order_cancel_replace::MultilegOrderCancelReplace),
    NetworkCounterpartySystemStatusRequest(messages::network_counterparty_system_status_request::NetworkCounterpartySystemStatusRequest),
    NetworkCounterpartySystemStatusResponse(messages::network_counterparty_system_status_response::NetworkCounterpartySystemStatusResponse),
    NewOrderCross(messages::new_order_cross::NewOrderCross),
    NewOrderList(messages::new_order_list::NewOrderList),
    NewOrderMultileg(messages::new_order_multileg::NewOrderMultileg),
    NewOrderSingle(messages::new_order_single::NewOrderSingle),
    News(messages::news::News),
    OrderCancelReject(messages::order_cancel_reject::OrderCancelReject),
    OrderCancelReplaceRequest(messages::order_cancel_replace_request::OrderCancelReplaceRequest),
    OrderCancelRequest(messages::order_cancel_request::OrderCancelRequest),
    OrderMassCancelReport(messages::order_mass_cancel_report::OrderMassCancelReport),
    OrderMassCancelRequest(messages::order_mass_cancel_request::OrderMassCancelRequest),
    OrderMassStatusRequest(messages::order_mass_status_request::OrderMassStatusRequest),
    OrderStatusRequest(messages::order_status_request::OrderStatusRequest),
    PositionMaintenanceReport(messages::position_maintenance_report::PositionMaintenanceReport),
    PositionMaintenanceRequest(messages::position_maintenance_request::PositionMaintenanceRequest),
    PositionReport(messages::position_report::PositionReport),
    Quote(messages::quote::Quote),
    QuoteCancel(messages::quote_cancel::QuoteCancel),
    QuoteRequest(messages::quote_request::QuoteRequest),
    QuoteRequestReject(messages::quote_request_reject::QuoteRequestReject),
    QuoteResponse(messages::quote_response::QuoteResponse),
    QuoteStatusReport(messages::quote_status_report::QuoteStatusReport),
    QuoteStatusRequest(messages::quote_status_request::QuoteStatusRequest),
    RFQRequest(messages::rfq_request::RFQRequest),
    RegistrationInstructions(messages::registration_instructions::RegistrationInstructions),
    RegistrationInstructionsResponse(messages::registration_instructions_response::RegistrationInstructionsResponse),
    RequestForPositions(messages::request_for_positions::RequestForPositions),
    RequestForPositionsAck(messages::request_for_positions_ack::RequestForPositionsAck),
    SecurityDefinition(messages::security_definition::SecurityDefinition),
    SecurityDefinitionRequest(messages::security_definition_request::SecurityDefinitionRequest),
    SecurityDefinitionUpdateReport(messages::security_definition_update_report::SecurityDefinitionUpdateReport),
    SecurityList(messages::security_list::SecurityList),
    SecurityListRequest(messages::security_list_request::SecurityListRequest),
    SecurityListUpdateReport(messages::security_list_update_report::SecurityListUpdateReport),
    SecurityStatus(messages::security_status::SecurityStatus),
    SecurityStatusRequest(messages::security_status_request::SecurityStatusRequest),
    SecurityTypeRequest(messages::security_type_request::SecurityTypeRequest),
    SecurityTypes(messages::security_types::SecurityTypes),
    SettlementInstructionRequest(messages::settlement_instruction_request::SettlementInstructionRequest),
    SettlementInstructions(messages::settlement_instructions::SettlementInstructions),
    TradeCaptureReport(messages::trade_capture_report::TradeCaptureReport),
    TradeCaptureReportAck(messages::trade_capture_report_ack::TradeCaptureReportAck),
    TradeCaptureReportRequest(messages::trade_capture_report_request::TradeCaptureReportRequest),
    TradeCaptureReportRequestAck(messages::trade_capture_report_request_ack::TradeCaptureReportRequestAck),
    TradingSessionList(messages::trading_session_list::TradingSessionList),
    TradingSessionListRequest(messages::trading_session_list_request::TradingSessionListRequest),
    TradingSessionStatus(messages::trading_session_status::TradingSessionStatus),
    TradingSessionStatusRequest(messages::trading_session_status_request::TradingSessionStatusRequest),
    UserRequest(messages::user_request::UserRequest),
    UserResponse(messages::user_response::UserResponse),
    /// MsgType not defined by this dictionary.
    Unknown(crate::Message),
}

/// Classify a generic message into its typed representation.
pub fn classify(msg: crate::Message) -> AnyMessage {
    match msg.msg_type().ok().as_deref().unwrap_or("") {
        "BL" => AnyMessage::AdjustedPositionReport(messages::adjusted_position_report::AdjustedPositionReport(msg)),
        "7" => AnyMessage::Advertisement(messages::advertisement::Advertisement(msg)),
        "J" => AnyMessage::AllocationInstruction(messages::allocation_instruction::AllocationInstruction(msg)),
        "P" => AnyMessage::AllocationInstructionAck(messages::allocation_instruction_ack::AllocationInstructionAck(msg)),
        "BM" => AnyMessage::AllocationInstructionAlert(messages::allocation_instruction_alert::AllocationInstructionAlert(msg)),
        "AS" => AnyMessage::AllocationReport(messages::allocation_report::AllocationReport(msg)),
        "AT" => AnyMessage::AllocationReportAck(messages::allocation_report_ack::AllocationReportAck(msg)),
        "AW" => AnyMessage::AssignmentReport(messages::assignment_report::AssignmentReport(msg)),
        "k" => AnyMessage::BidRequest(messages::bid_request::BidRequest(msg)),
        "l" => AnyMessage::BidResponse(messages::bid_response::BidResponse(msg)),
        "j" => AnyMessage::BusinessMessageReject(messages::business_message_reject::BusinessMessageReject(msg)),
        "AY" => AnyMessage::CollateralAssignment(messages::collateral_assignment::CollateralAssignment(msg)),
        "BB" => AnyMessage::CollateralInquiry(messages::collateral_inquiry::CollateralInquiry(msg)),
        "BG" => AnyMessage::CollateralInquiryAck(messages::collateral_inquiry_ack::CollateralInquiryAck(msg)),
        "BA" => AnyMessage::CollateralReport(messages::collateral_report::CollateralReport(msg)),
        "AX" => AnyMessage::CollateralRequest(messages::collateral_request::CollateralRequest(msg)),
        "AZ" => AnyMessage::CollateralResponse(messages::collateral_response::CollateralResponse(msg)),
        "AK" => AnyMessage::Confirmation(messages::confirmation::Confirmation(msg)),
        "AU" => AnyMessage::ConfirmationAck(messages::confirmation_ack::ConfirmationAck(msg)),
        "BH" => AnyMessage::ConfirmationRequest(messages::confirmation_request::ConfirmationRequest(msg)),
        "BO" => AnyMessage::ContraryIntentionReport(messages::contrary_intention_report::ContraryIntentionReport(msg)),
        "t" => AnyMessage::CrossOrderCancelReplaceRequest(messages::cross_order_cancel_replace_request::CrossOrderCancelReplaceRequest(msg)),
        "u" => AnyMessage::CrossOrderCancelRequest(messages::cross_order_cancel_request::CrossOrderCancelRequest(msg)),
        "AA" => AnyMessage::DerivativeSecurityList(messages::derivative_security_list::DerivativeSecurityList(msg)),
        "z" => AnyMessage::DerivativeSecurityListRequest(messages::derivative_security_list_request::DerivativeSecurityListRequest(msg)),
        "Q" => AnyMessage::DontKnowTrade(messages::dont_know_trade::DontKnowTrade(msg)),
        "C" => AnyMessage::Email(messages::email::Email(msg)),
        "BN" => AnyMessage::ExecutionAcknowledgement(messages::execution_acknowledgement::ExecutionAcknowledgement(msg)),
        "8" => AnyMessage::ExecutionReport(messages::execution_report::ExecutionReport(msg)),
        "6" => AnyMessage::IOI(messages::ioi::IOI(msg)),
        "K" => AnyMessage::ListCancelRequest(messages::list_cancel_request::ListCancelRequest(msg)),
        "L" => AnyMessage::ListExecute(messages::list_execute::ListExecute(msg)),
        "N" => AnyMessage::ListStatus(messages::list_status::ListStatus(msg)),
        "M" => AnyMessage::ListStatusRequest(messages::list_status_request::ListStatusRequest(msg)),
        "m" => AnyMessage::ListStrikePrice(messages::list_strike_price::ListStrikePrice(msg)),
        "X" => AnyMessage::MarketDataIncrementalRefresh(messages::market_data_incremental_refresh::MarketDataIncrementalRefresh(msg)),
        "V" => AnyMessage::MarketDataRequest(messages::market_data_request::MarketDataRequest(msg)),
        "Y" => AnyMessage::MarketDataRequestReject(messages::market_data_request_reject::MarketDataRequestReject(msg)),
        "W" => AnyMessage::MarketDataSnapshotFullRefresh(messages::market_data_snapshot_full_refresh::MarketDataSnapshotFullRefresh(msg)),
        "i" => AnyMessage::MassQuote(messages::mass_quote::MassQuote(msg)),
        "b" => AnyMessage::MassQuoteAcknowledgement(messages::mass_quote_acknowledgement::MassQuoteAcknowledgement(msg)),
        "AC" => AnyMessage::MultilegOrderCancelReplace(messages::multileg_order_cancel_replace::MultilegOrderCancelReplace(msg)),
        "BC" => AnyMessage::NetworkCounterpartySystemStatusRequest(messages::network_counterparty_system_status_request::NetworkCounterpartySystemStatusRequest(msg)),
        "BD" => AnyMessage::NetworkCounterpartySystemStatusResponse(messages::network_counterparty_system_status_response::NetworkCounterpartySystemStatusResponse(msg)),
        "s" => AnyMessage::NewOrderCross(messages::new_order_cross::NewOrderCross(msg)),
        "E" => AnyMessage::NewOrderList(messages::new_order_list::NewOrderList(msg)),
        "AB" => AnyMessage::NewOrderMultileg(messages::new_order_multileg::NewOrderMultileg(msg)),
        "D" => AnyMessage::NewOrderSingle(messages::new_order_single::NewOrderSingle(msg)),
        "B" => AnyMessage::News(messages::news::News(msg)),
        "9" => AnyMessage::OrderCancelReject(messages::order_cancel_reject::OrderCancelReject(msg)),
        "G" => AnyMessage::OrderCancelReplaceRequest(messages::order_cancel_replace_request::OrderCancelReplaceRequest(msg)),
        "F" => AnyMessage::OrderCancelRequest(messages::order_cancel_request::OrderCancelRequest(msg)),
        "r" => AnyMessage::OrderMassCancelReport(messages::order_mass_cancel_report::OrderMassCancelReport(msg)),
        "q" => AnyMessage::OrderMassCancelRequest(messages::order_mass_cancel_request::OrderMassCancelRequest(msg)),
        "AF" => AnyMessage::OrderMassStatusRequest(messages::order_mass_status_request::OrderMassStatusRequest(msg)),
        "H" => AnyMessage::OrderStatusRequest(messages::order_status_request::OrderStatusRequest(msg)),
        "AM" => AnyMessage::PositionMaintenanceReport(messages::position_maintenance_report::PositionMaintenanceReport(msg)),
        "AL" => AnyMessage::PositionMaintenanceRequest(messages::position_maintenance_request::PositionMaintenanceRequest(msg)),
        "AP" => AnyMessage::PositionReport(messages::position_report::PositionReport(msg)),
        "S" => AnyMessage::Quote(messages::quote::Quote(msg)),
        "Z" => AnyMessage::QuoteCancel(messages::quote_cancel::QuoteCancel(msg)),
        "R" => AnyMessage::QuoteRequest(messages::quote_request::QuoteRequest(msg)),
        "AG" => AnyMessage::QuoteRequestReject(messages::quote_request_reject::QuoteRequestReject(msg)),
        "AJ" => AnyMessage::QuoteResponse(messages::quote_response::QuoteResponse(msg)),
        "AI" => AnyMessage::QuoteStatusReport(messages::quote_status_report::QuoteStatusReport(msg)),
        "a" => AnyMessage::QuoteStatusRequest(messages::quote_status_request::QuoteStatusRequest(msg)),
        "AH" => AnyMessage::RFQRequest(messages::rfq_request::RFQRequest(msg)),
        "o" => AnyMessage::RegistrationInstructions(messages::registration_instructions::RegistrationInstructions(msg)),
        "p" => AnyMessage::RegistrationInstructionsResponse(messages::registration_instructions_response::RegistrationInstructionsResponse(msg)),
        "AN" => AnyMessage::RequestForPositions(messages::request_for_positions::RequestForPositions(msg)),
        "AO" => AnyMessage::RequestForPositionsAck(messages::request_for_positions_ack::RequestForPositionsAck(msg)),
        "d" => AnyMessage::SecurityDefinition(messages::security_definition::SecurityDefinition(msg)),
        "c" => AnyMessage::SecurityDefinitionRequest(messages::security_definition_request::SecurityDefinitionRequest(msg)),
        "BP" => AnyMessage::SecurityDefinitionUpdateReport(messages::security_definition_update_report::SecurityDefinitionUpdateReport(msg)),
        "y" => AnyMessage::SecurityList(messages::security_list::SecurityList(msg)),
        "x" => AnyMessage::SecurityListRequest(messages::security_list_request::SecurityListRequest(msg)),
        "BK" => AnyMessage::SecurityListUpdateReport(messages::security_list_update_report::SecurityListUpdateReport(msg)),
        "f" => AnyMessage::SecurityStatus(messages::security_status::SecurityStatus(msg)),
        "e" => AnyMessage::SecurityStatusRequest(messages::security_status_request::SecurityStatusRequest(msg)),
        "v" => AnyMessage::SecurityTypeRequest(messages::security_type_request::SecurityTypeRequest(msg)),
        "w" => AnyMessage::SecurityTypes(messages::security_types::SecurityTypes(msg)),
        "AV" => AnyMessage::SettlementInstructionRequest(messages::settlement_instruction_request::SettlementInstructionRequest(msg)),
        "T" => AnyMessage::SettlementInstructions(messages::settlement_instructions::SettlementInstructions(msg)),
        "AE" => AnyMessage::TradeCaptureReport(messages::trade_capture_report::TradeCaptureReport(msg)),
        "AR" => AnyMessage::TradeCaptureReportAck(messages::trade_capture_report_ack::TradeCaptureReportAck(msg)),
        "AD" => AnyMessage::TradeCaptureReportRequest(messages::trade_capture_report_request::TradeCaptureReportRequest(msg)),
        "AQ" => AnyMessage::TradeCaptureReportRequestAck(messages::trade_capture_report_request_ack::TradeCaptureReportRequestAck(msg)),
        "BJ" => AnyMessage::TradingSessionList(messages::trading_session_list::TradingSessionList(msg)),
        "BI" => AnyMessage::TradingSessionListRequest(messages::trading_session_list_request::TradingSessionListRequest(msg)),
        "h" => AnyMessage::TradingSessionStatus(messages::trading_session_status::TradingSessionStatus(msg)),
        "g" => AnyMessage::TradingSessionStatusRequest(messages::trading_session_status_request::TradingSessionStatusRequest(msg)),
        "BE" => AnyMessage::UserRequest(messages::user_request::UserRequest(msg)),
        "BF" => AnyMessage::UserResponse(messages::user_response::UserResponse(msg)),
        _ => AnyMessage::Unknown(msg),
    }
}