Function publish_messages

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

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.