Crate oa_gateway_stomp

Source
Expand description

STOMP 1.2 client adapter for ActiveMQ Classic (and any STOMP broker).

This is a client, not a server, and it is not JMS. Java CAL peers still speak OpenWire; ActiveMQ routes the same topic between OpenWire and STOMP when destinations match. The engine sees only oa_gateway_core::Envelope values. This crate maps /topic/{name} onto oa_gateway_core::RouteKey::topic and stamps oag.* headers so a MESSAGE is not SENDed back to the broker that just delivered it.

StompAdapter::serve (and oa_gateway_adapter::Adapter::run) connect, subscribe the configured topics both ways, and retry while StompConfig::reconnect is set. A panic in a session is isolated on a child task; StompConfig::on_panic chooses abort or reconnect. The host does not restart a finished run.

The codec (Frame, decode_one) is public so tests can speak STOMP without this adapter.

Modules§

  • adapter 🔒
    ActiveMQ STOMP client adapter. Protocol control stays here; data crosses the engine.
  • client 🔒
    TCP STOMP session: handshake, framed read/write.
  • codec 🔒
    STOMP 1.2 frames. Text commands and headers; opaque body bytes.
  • config 🔒
  • dest 🔒
    STOMP destination ↔ engine RouteKey mapping.
  • secret 🔒
    A string that must not reach a log.

Structs§

  • DestinationMap
    /topic/ prefix used by ActiveMQ STOMP for JMS topics.
  • Frame
    One STOMP frame (command + headers + body).
  • Secret
    Wraps a credential — the STOMP passcode — so a stray Debug or Display on a config struct cannot print it.
  • StompAdapter
    STOMP client that bridges configured topics both ways.
  • StompConfig
    Runtime settings for a STOMP client session.

Enums§

  • CodecError
    Why a frame could not be decoded, or why a write failed.
  • OnPanic
    What an adapter does when its session task panics.

Constants§

  • DEFAULT_MAX_FRAME_SIZE
    Largest single frame (header block plus body) accepted from a peer.
  • HDR_ID
    Envelope crate::MessageId, written on outbound frames.
  • HDR_ORIGIN
    Which adapter last published this envelope onto the engine.
  • HDR_STOMP_DEST
    STOMP destination as received. Stamped inbound; stripped on outbound because stomp.* headers are not copied.
  • HDR_TOPIC
    Engine topic, copied onto a native frame when the protocol has a place for it.
  • HDR_TYPE_HINT
    Engine type hint, copied onto a native frame when present.

Functions§