pub async fn handle_replies(
channel: Channel,
config: RabbitMQConfig,
rabbitmq_receiver: Receiver<Reply>,
command_id_pool_mutex: Arc<Mutex<CommandID>>,
) -> Result<(), String>Expand description
Handles replies received from the RabbitMQ receiver channel and publishes them to RabbitMQ.
ยงArguments
channel- The Lapin channel to use for publishing messages.config- The RabbitMQ configuration.rabbitmq_receiver- The receiver channel from which replies are received.command_id_pool_mutex- A mutex-protected CommandID pool for tracking command UUIDs.