Skip to main content

MessageHandler

Trait MessageHandler 

Source
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§

Source

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 message
  • header - Decoded message header
  • buffer - Full message buffer (including header)
  • responder - Interface for sending responses

Provided Methods§

Source

fn on_session_start(&self, _session_id: u64)

Called when a new session is established.

§Arguments
  • session_id - ID of the new session
Source

fn on_session_end(&self, _session_id: u64)

Called when a session ends.

§Arguments
  • session_id - ID of the ended session
Source

fn on_error(&self, _session_id: u64, _error: &str)

Called on decode error.

§Arguments
  • session_id - ID of the session
  • error - Description of the error

Implementors§