Struct StompPeer

pub struct StompPeer {
    stream: MaybeTlsStream<TcpStream>,
    buf: Vec<u8>,
}

Raw STOMP client for tests: CONNECT, SUBSCRIBE, SEND, recv.

Not the gateway adapter. Use this as the “other side” of start_mini_broker or a live ActiveMQ.

Fields

stream: MaybeTlsStream<TcpStream>

buf: Vec<u8>

Implementations

impl StompPeer

pub async fn connect(addr: SocketAddr) -> Self

CONNECT 1.2 / host / / no heartbeats, then wait for CONNECTED.

Panics if the socket cannot be opened or the first frame is not CONNECTED.

pub async fn connect_tls(addr: SocketAddr, tls: &ClientTls) -> Self

As Self::connect, negotiating TLS per tls before CONNECT.

Panics if the socket cannot be opened, the TLS handshake fails, or the first frame after CONNECT is not CONNECTED.

async fn handshake(stream: MaybeTlsStream<TcpStream>) -> Self

pub async fn subscribe(&mut self, id: &str, dest: &str)

SUBSCRIBE with ack:auto. Does not wait for a receipt.

pub async fn send(&mut self, dest: &str, body: &[u8], extra: &[(&str, &str)])

SEND body to dest, then any extra headers.

pub async fn recv(&mut self) -> Frame

Next complete frame. Waits up to two seconds.

Panics on timeout or a clean close.