Module adapter

ActiveMQ STOMP client adapter. Protocol control stays here; data crosses the engine.

This is a client, not a server. The retry loop sits outside one broker session. Each session runs on a child task so a panic is a join error. StompConfig::on_panic chooses abort or reconnect. The host does not restart a finished run.

Structs

• StompAdapter
  STOMP client that bridges configured topics both ways.

Functions

• forward_outbound 🔒
  Writes a SEND for one engine delivery.
• inbound_publish 🔒
  Publishes a MESSAGE onto the engine.
• log_drops 🔒