Function inbound_publish

async fn inbound_publish(
    adapter: &StompAdapter,
    engine: &Arc<Engine>,
    map: &DestinationMap,
    frame: &Frame,
) -> Result<(), String>

Publishes a MESSAGE onto the engine.

Topic comes from oag.topic or by stripping the destination prefix. Type hint comes from oag.type_hint or by sniffing the body. The envelope is stamped with this adapter’s id so the outbound path can skip it. A-GRA wrappers publish wrapper and inner as two envelopes.

Errors

Returns a message if destination is missing, outside the prefix, or unwrap fails.