tencent cloud

<!-- in your <dependencies> block -->
  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-client</artifactId>
      <version>4.9.7</version>
  </dependency>

  <dependency>
      <groupId>org.apache.rocketmq</groupId>
      <artifactId>rocketmq-acl</artifactId>
      <version>4.9.7</version>
  </dependency>

// Instantiate the message producer
   DefaultMQProducer producer = new DefaultMQProducer(
       groupName,
       new AclClientRPCHook(new SessionCredentials(accessKey, secretKey)) // ACL permission
   );
   // Set the NameServer's address. The address is in the format of an access address: xxx.tencenttdmq.com:8080
   producer.setNamesrvAddr(nameserver);
   // Start the producer instance.
   producer.start();

   for (int i = 0; i < 10; i++) {
          // Create a message instance, and configure the topic and message content.
          Message msg = new Message(topic_name, ("Hello RocketMQ " + i).getBytes(RemotingHelper.DEFAULT_CHARSET));
          // Send the message
          SendResult sendResult = producer.send(msg);
          System.out.printf("%s%n", sendResult);
   }

// Instantiate the consumer
DefaultMQPushConsumer pushConsumer = new DefaultMQPushConsumer(
            groupName,                                              
            new AclClientRPCHook(new SessionCredentials(accessKey, secretKey))); // ACL permissions
        // Set the NameServer address
pushConsumer.setNamesrvAddr(nameserver);
        // Subscribe to a topic
pushConsumer.subscribe(topic_name, "*");
      // Register a callback implementation class to process messages pulled from the broker
pushConsumer.registerMessageListener((MessageListenerConcurrently) (msgs, context) -> {
          // Message processing logic
          System.out.printf("%s Receive New Messages: %s %n", Thread.currentThread().getName(), msgs);
          // Mark the message as successfully consumed, and return consumption status based on the consumption situation
          return ConsumeConcurrentlyStatus.CONSUME_SUCCESS;
      });
      // Start the consumer instance
pushConsumer.start();