Skip to main content

republish_external_message

Function republish_external_message 

Source
pub fn republish_external_message(message: &BusMessage) -> Result<()>
Expand description

Decodes an externally-received BusMessage and republishes it onto the internal bus.

The message payload_type header selects the concrete type and the message encoding selects the wire codec, so the message is decoded with the producer’s encoding rather than the local configuration. Republishing runs under a SuppressExternalGuard so the message is not forwarded straight back out through external egress, which would create an echo loop on a node that has both external ingress and egress.

§Errors

Returns an error if a supported payload cannot be decoded. Unsupported type/encoding pairs are skipped with a warning.