tencent cloud

// Authentication information
Credential cred = Credential(SECRET_ID, SECRET_KEY);

HttpProfile httpProfile = HttpProfile();
httpProfile.SetEndpoint(ENDPOINT);

ClientProfile clientProfile = ClientProfile();
clientProfile.SetHttpProfile(httpProfile);
// Create the TDMQ client
TdmqClient client = TdmqClient(cred, REGION, clientProfile);

 SendMessagesRequest req = SendMessagesRequest();
 // Set the authorized role token
 req.SetStringToken(token);
 // Set the authorized role name
 req.SetProducerName(userName);
 // Set the topic name in the format of cluster (tenant) ID/namespace/topic name
 req.SetTopic(topicName);
 // Message content
 req.SetPayload("this is a new message.");
 // Set the message sending timeout period
 req.SetSendTimeout(3000);
 // Send the message
 auto outcome = client.SendMessages(req);
 if (!outcome.IsSuccess()) {
     cout << outcome.GetError().PrintAll() << endl;
     return -1;
 }
 // Get the result
 SendMessagesResponse resp = outcome.GetResult();

 ReceiveMessageRequest req = ReceiveMessageRequest();
 // Set the topic name in the format of cluster (tenant) ID/namespace/topic name
 req.SetTopic(topicName);
 // Set the subscription name
 req.SetSubscriptionName(subName);
 // Messages received by the consumer will first be stored in the `receiverQueueSize` queue to tune the message receiving rate.
 req.SetReceiverQueueSize(10);
 // It is used to determine the position where the consumer initially receives messages. Valid values: `Earliest`, `Latest`.
 req.SetSubInitialPosition("Latest");

 // Receive the message
 auto outcome = client.ReceiveMessage(req);
 if (!outcome.IsSuccess()) {
     cout << outcome.GetError().PrintAll() << endl;
     return -1;
 }
 // Get the result
 ReceiveMessageResponse resp = outcome.GetResult();


 AcknowledgeMessageRequest req = AcknowledgeMessageRequest();
 // ID of the acknowledged message
 req.SetMessageId(messageId);
 // Set the topic name in the format of cluster (tenant) ID/namespace/topic name
 req.SetAckTopic(topicName);
 // Set the message subscription
 req.SetSubName(subName);
 // Acknowledge the message
 auto outcome = client.AcknowledgeMessage(req);
 if (!outcome.IsSuccess()) {
     cout << outcome.GetError().PrintAll() << endl;
     return -1;
 }
 // Get the result
 AcknowledgeMessageResponse resp = outcome.GetResult();