Struct AmqpHandler 

pub struct AmqpHandler;

Trait Implementations

impl ProtocolHandler for AmqpHandler

fn parse_request(&self, buf: &[u8]) -> Option<String>

Parse request bytes → summary for event list

fn parse_response(&self, buf: &[u8]) -> Option<String>

Parse response bytes → short summary

fn format_response_detail(&self, buf: &[u8]) -> Option<String>

Format response detail (for Detail panel)

fn is_frame_based(&self) -> bool

Is this a frame-based protocol with custom proxy logic? (AMQP)

fn default_port(&self) -> u16

Default port for this protocol.

fn extract_full_command(&self, buf: &[u8]) -> Option<String>

Extract full command from request (for Detail panel, copy, edit)

fn to_replay_command(&self, ev: &ProxyEvent) -> String

Generate a replayable command string (for yank/copy)

fn needs_request_buffering(&self) -> bool

Does this protocol need request buffering across reads?

fn needs_response_buffering(&self) -> bool

Does this protocol need response buffering across reads?

fn request_complete(&self, _buf: &[u8]) -> bool

Is the request buffer complete?

fn response_complete(&self, _buf: &[u8]) -> bool

Is the response buffer complete?

fn message_length(&self, _buf: &[u8]) -> Option<usize>

Length of the first complete message in buf (for discarding unparseable messages). The length should include any header bytes (i.e., total bytes to drain). Returns None if the protocol doesn’t have self-describing message boundaries.

fn capture_handshake( &self, _payload: &[u8], _direction: Direction, ) -> HandshakeAction

In capture mode, should this packet be skipped? (e.g., connection handshake) handshake_done is false until this method returns HandshakeAction::Done.