Добро пожаловать в MQ-Assistant!

implementation("cool.doudou:mq-assistant-boot-starter:latest")

pulsar:
  service-url: pulsar://127.0.0.1:6650
  subscription-name: sub-celery
  subscription-type: Shared

/**
 * Связывание производителя с темами
 */
@MqProducer(topics = {"celery"})
@Component
public class MqComponent {
}

/**
 * Связывание потребителя с темами
 */
@Component
public class MqComponent {
    @MqConsumer(topics = {"celery"})
    public void receive(String topic, byte[] msg) {
        System.out.println("consumer: topic[" + topic + "] => " + new String(msg));
    }
}

/**
 * Отправка сообщений
 */
@AllArgsConstructor
@Service
public class MqServiceImpl {
    private MqHelper mqHelper;

    public void test() {
        // Синхронно
        String msgId = mqHelper.send("celery", "hello");
        System.out.println("send: " + msgId);

        // Асинхронно
        mqHelper.sendAsync("celery", "您好Async", System.out::println);

        // Синхронно
        String msgId = mqHelper.send("celery", new byte[]{0x01, 0x02, 0x03, 0x04});
        System.out.println("send: " + msgId);

        // Асинхронно
        mqHelper.sendAsync("celery", new byte[]{0x01, 0x02, 0x03, 0x04}, System.out::println);
    }
}