tencent cloud

   auto evbase = event_base_new();
   LibEventHandlerMyError hndl(evbase);

   // Establish a connection
   AMQP::TcpConnection connection(&hndl, AMQP::Address(
       "amqp://admin:eyJrZXlJZC...@amqp-xxx.rabbitmq.ap-sh.public.tencenttdmq.com:5672/amqp-xxx|vhost-cpp"));
       // The service address is in the format of “amqp://username:password@host:port/vhost”.
   // Create a channel
   AMQP::TcpChannel channel(&connection);
   channel.onError([&evbase](const char *message) {
       std::cout << "Channel error: " << message << std::endl;
       event_base_loopbreak(evbase);
   });


   // Declare an exchange
   channel.declareExchange(exchange_name, AMQP::ExchangeType::direct);

   // Send messages to the exchange
   channel.publish(exchange_name, routing_key, "Hello client this is a info message");

   event_base_dispatch(evbase);
   event_base_free(evbase);


ConnHandler handler;
// Establish a connection
AMQP::TcpConnection connection(handler, AMQP::Address(host, part, AMQP::Login(username, password), vhost));
// Create a channel
AMQP::TcpChannel channel(&connection);
channel.onError([&handler](const char *message) {
        std::cout << "Channel error: " << message << std::endl;
        handler.Stop();
});


// Declare an exchange
channel.declareExchange(exchange_name, AMQP::ExchangeType::direct);
// Declare a message queue
channel.declareQueue(queue_name, AMQP::durable);
// Bind the message queue to the exchange
channel.bindQueue(exchange_name, queue_name, routing_key);


// Subscribe to the message
channel.consume(queue_name)
        .onReceived
        (
        [&channel](const AMQP::Message &msg, uint64_t tag, bool redelivered) {
                // Process the message
                std::cout << "Received: " << msg.body() << std::endl;
                // Acknowledge the message, or reject it if the consumption failed
                channel.ack(tag);
        }
);
handler.Start();