Китайская документация

# Центральный репозиторий: https://search.maven.org/search?q=rmq-api
<dependency>
  <groupId>com.gitee.nuliing</groupId>
  <artifactId>rmq-api</artifactId>
  <version>${последняя стабильная версия}</version>
</dependency>

import org.apache.dubbo.config.annotation.Reference;
import com.cn.rmq.api.service.IRmqService;

@Reference
private IRmqService rmqService;

public void doBusiness() {
        // Пользовательское имя очереди
        String queue = "test.queue";
        // Содержимое сообщения, если передаётся объект, рекомендуется преобразовать его в строку json
        String messageContent = "......";

        // Вызов RMQ для предварительной отправки сообщения
        String messageId = rmqService.createPreMessage(queue, messageContent);

        // Выполнение бизнес-операции
        ...
        ...

        // Асинхронный вызов RMQ для подтверждения отправки сообщения
        RpcContext.getContext().asyncCall(() -> rmqService.confirmAndSendMessage(messageId));
    }

public void handleMsg(RmqMessage msg) {
        try {
            String messageContent = msg.getMessageBody();

            // Выполнение бизнес-операции
            ...
            ...

            // Уведомление RMQ об успешном потреблении сообщения
            // Если используется directSendMessage RMQ, уведомление не требуется
            if (StringUtils.isNotBlank(msg.getMessageId())) {
                rmqService.deleteMessageById(msg.getMessageId());
            }
        } catch (Exception e) {
            ...
        }
    }