oa_gateway_stomp::adapter

Function forward_outbound

Source
async fn forward_outbound(
    adapter: &StompAdapter,
    writer: &mut FrameWriter,
    map: &DestinationMap,
    delivery: Delivery,
) -> Result<(), String>
Expand description

Writes a SEND for one engine delivery.

Skips envelopes whose oag.origin_adapter is this adapter, so a MESSAGE just taken from the broker is not sent back. stomp.* headers and oag.origin_adapter are not copied onto the wire.

ยงErrors

Returns a message if the SEND cannot be written.