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 token
    secretKey, // Role name
    "");
// Set the full namespace name
producer.setNameSpace(namespace);
// Make sure all parameters are configured before the start
producer.start();

// Initialize message content
   MQMessage msg(
       topicName,  // Topic name
       TAGS,        // Message tag
       KEYS,        // 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();

// Listen on 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 if the consumption is successful
           return CONSUME_SUCCESS;
           // Return RECONSUME_LATER if the consumption failed. The message will be consumed again.
           // 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");
   
   // Register a custom listener function to process the received messages and return the processing results
   ExampleMessageListener *messageListener = new ExampleMessageListener();
   // Subscribe to the message
   consumer->subscribe(topicName, TAGS);
   // Set the message listener
   consumer->registerMessageListener(messageListener);
   
   // After the preparations, you must call the start function before the consumption can start.
   consumer->start();

// Release resources
consumer->shutdown();