publish_messages

Function publish_messages 

Source
pub async fn publish_messages(
    rx: UnboundedReceiver<BusMessage>,
    trader_id: TraderId,
    instance_id: UUID4,
    config: MessageBusConfig,
) -> Result<()>
Expand description

Publishes messages received on rx to Redis streams for the given trader_id and instance_id, using config.

ยงErrors

Returns an error if:

  • The database configuration is missing in config.
  • Establishing the Redis connection fails.
  • Any Redis command fails during publishing.