Function svc_telemetry::amqp::init_mq

source · 
pub async fn init_mq(config: Config) -> Result<Channel, AMQPError>
Expand description

Initializes the AMQP connection. Creates the telemetry exchange and queues.