nautilus_infrastructure::redis::msgbus

Function publish_messages

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