tencent cloud

// Set the producer group name
DefaultMQProducer producer(groupName);
// Set the service access address
producer.setNamesrvAddr(nameserver);
// Set user permissions
producer.setSessionCredentials(
    accessKey,  // Role key
    secretKey, // Role name
    "");
// Set the namespace (full namespace name)
producer.setNameSpace(namespace);
// Ensure that the parameters are set before initiation
producer.start();

// Initialize message content
   MQMessage msg(
       topicName,  // Topic name
       TAGS,        // Message tag
       KEYS,        // Business message key
       "Hello cpp client, this is a message."  // Message content
   );

   try {
       // Send the message
       SendResult sendResult = producer.send(msg);
       std::cout << "SendResult:" << sendResult.getSendStatus() << ", Message ID: " << sendResult.getMsgId()
           << std::endl;
   } catch (MQException e) {
       std::cout << "ErrorCode: " << e.GetError() << " Exception:" << e.what() << std::endl;
   }

// Release resources
   producer.shutdown();

// Monitor messages
   class ExampleMessageListener : public MessageListenerConcurrently {
   public:
       ConsumeStatus consumeMessage(const std::vector<MQMessageExt> &msgs) {
           for (auto item = msgs.begin(); item != msgs.end(); item++) {
               // Business
               std::cout << "Received Message Topic:" << item->getTopic() << ", MsgId:" << item->getMsgId() << ", TAGS:"
                         << item->getTags() << ", KEYS:" << item->getKeys() << ", Body:" << item->getBody() << std::endl;
           }
           // Return `CONSUME_SUCCESS` when consumption is successful
           return CONSUME_SUCCESS;
           // Return `RECONSUME_LATER` when consumption fails. The message will be re-consumed
           // return RECONSUME_LATER;
       }
   };

   // Initialize the consumer
   DefaultMQPushConsumer *consumer = new DefaultMQPushConsumer(groupName);
   // Set the service address
   consumer->setNamesrvAddr(nameserver);
   // Set user permissions
   consumer->setSessionCredentials(
       accessKey,
       secretKey, 
       "");
   // Set the namespace
   consumer->setNameSpace(namespace);
   // Set the instance name
   consumer->setInstanceName("CppClient");

   // Please register the custom listening function to process the received messages and return the corresponding processing results.
   ExampleMessageListener *messageListener = new ExampleMessageListener();
   // Subscribe to the message
   consumer->subscribe(topicName, TAGS);
   // Set the message listener
   consumer->registerMessageListener(messageListener);

   // After the preparations are complete, the startup function must be called for normal operation.
   consumer->start();

// Release resources
consumer->shutdown();