Module stomp

Mini STOMP broker, a peer client, and an adapter starter.

start_mini_broker is an in-process stand-in for ActiveMQ Classic: exact-destination fan-out, no auth, no persistence, no heartbeats. Most tests need no Docker. start_stomp_adapter turns reconnect off so a failed session fails the test instead of looping. Helpers panic on timeout or a surprising frame.

Structs

• BrokerState 🔒
  Destinations → subscribers, plus a process-wide message-id.
• MiniBroker
  In-process STOMP 1.2 broker on an ephemeral port.
• StompPeer
  Raw STOMP client for tests: CONNECT, SUBSCRIBE, SEND, recv.
• Sub 🔒
  One SUBSCRIBE: which connection, which id, and where to write MESSAGE frames.

Functions

• dispatch 🔒
  Handles one client frame. Unknown commands get an ERROR. SEND copies headers except destination and assigns message-id.
• handle_conn 🔒
  Reads frames until the peer closes or shutdown fires, then drops this connection’s subscriptions.
• run_broker 🔒
  Accepts connections until shutdown. Each socket is its own task.
• start_mini_broker
  Binds 127.0.0.1:0 and serves until MiniBroker::shutdown.
• start_mini_broker_mtls
  As start_mini_broker_tls, but the broker also requires and verifies a client certificate issued by client_ca from every connection.
• start_mini_broker_tls
  As start_mini_broker, but the broker terminates TLS with certs.
• start_mini_broker_with 🔒
• start_stomp_adapter
  Starts StompAdapter toward broker and waits until it is subscribed.
• start_stomp_adapter_with
  As start_stomp_adapter, with the config open for editing first — for example to set StompConfig::tls.