process_command

clu_middleware_tron::rabbitmq

Function process_command 

Source 
pub async fn process_command(
    tcp_sender: &Sender<BytesMut>,
    delivery: &Delivery,
    command_id_pool: &Arc<Mutex<CommandID>>,
)
Expand description

Processes a command received from RabbitMQ and sends it to the actor.

ยงArguments

  • tcp_sender - The sender channel to send TCP commands.
  • delivery - The RabbitMQ delivery containing the command.
  • command_id_pool - A mutex-protected CommandID pool for tracking command UUIDs.