handle_replies

Function handle_replies 

Source
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.