tencent cloud

<!-- in your <dependencies> block -->
  <dependency>
      <groupId>com.aliyun.mq</groupId>
      <artifactId>mq-http-sdk</artifactId>
      <version>1.0.3</version>
  </dependency>

   // Get the client
   MQClient mqClient = new MQClient(endpoint, accessKey, secretKey);

   // Get the topic consumer  
   MQProducer consumer = mqClient.getConsumer(namespace, topicName, groupName, "TAG");

do {
    List<Message> messages = null;

    try {
        // Long polling consumes messages sequentially. Although the messages obtained may be from multiple partitions, the messages in a partition will definitely be sequential.
        // For sequential consumption, as long as a message in a partition hasn't been acknowledged to be consumed successfully, it will be consumed next time for this partition.
        // For a partition, the next batch of messages can only be consumed after all previous messages are acknowledged to be consumed successfully.
        messages = consumer.consumeMessageOrderly(
                Integer.parseInt(batchSize),
                Integer.parseInt(waitSeconds)
        );
    } catch (Throwable e) {
        e.printStackTrace();
    }
    if (messages == null || messages.isEmpty()) {
        System.out.println(Thread.currentThread().getName() + ": no new message, continue!");
        continue;
    }

    for (Message message : messages) {
        System.out.println("Receive message: " + message);
    }

    {
        List<String> handles = new ArrayList<String>();
        for (Message message : messages) {
            handles.add(message.getReceiptHandle());
        }

        try {
            consumer.ackMessage(handles);
        } catch (Throwable e) {
            if (e instanceof AckMessageException) {
                AckMessageException errors = (AckMessageException) e;
                System.out.println("Ack message fail, requestId is:" + errors.getRequestId() + ", fail handles:");
                if (errors.getErrorMessages() != null) {
                    for (String errorHandle :errors.getErrorMessages().keySet()) {
                        System.out.println("Handle:" + errorHandle + ", ErrorCode:" + errors.getErrorMessages().get(errorHandle).getErrorCode()
                                + ", ErrorMsg:" + errors.getErrorMessages().get(errorHandle).getErrorMessage());
                    }
                }
                continue;
            }
            e.printStackTrace();
        }
    }
} while (true);