start_rabbitmq_service

Function start_rabbitmq_service 

Source
pub async fn start_rabbitmq_service(
    config: RabbitMQConfig,
    tcp_sender: Sender<BytesMut>,
    rabbitmq_receiver: Receiver<Reply>,
) -> Result<(), String>
Expand description

Starts the RabbitMQ service to listen for commands and handle replies.

ยงArguments

  • config - The RabbitMQ configuration.
  • tcp_sender - The sender channel to send TCP commands.
  • rabbitmq_receiver - The receiver channel to receive replies from TCP.