pub trait MessageHandler: Send + Sync {
// Required method
fn on_message(
&self,
session_id: u64,
header: &MessageHeader,
buffer: &[u8],
responder: &dyn Responder,
);
// Provided methods
fn on_session_start(&self, _session_id: u64) { ... }
fn on_session_end(&self, _session_id: u64) { ... }
fn on_error(&self, _session_id: u64, _error: &str) { ... }
}Expand description
Trait for handling incoming SBE messages.
Required Methods§
Sourcefn on_message(
&self,
session_id: u64,
header: &MessageHeader,
buffer: &[u8],
responder: &dyn Responder,
)
fn on_message( &self, session_id: u64, header: &MessageHeader, buffer: &[u8], responder: &dyn Responder, )
Called when a complete SBE message is received.
§Arguments
session_id- ID of the session that sent the messageheader- Decoded message headerbuffer- Full message buffer (including header)responder- Interface for sending responses