<dependency>
    <groupId>xin.wjtree.qmq</groupId>
    <artifactId>qmq-spring-boot-starter</artifactId>
    <version>1.0.1</version>
</dependency>

spring:
  application:
    name: qmq-demo
  qmq:
    # qmq appcode, обязательно
    app-code: qmq-demo
    # qmq metaserver, обязательно
    meta-server: http://127.0.0.1:8080/meta/address

    # конфигурация производителя, настройка пула потоков для отправки сообщений, опционально
    producer:
      # количество потоков отправки, по умолчанию 3
      send-threads: 2
      # максимальный размер пакета при каждой отправке, по умолчанию 30
      send-batch: 30
      # если отправка сообщения не удалась, количество повторных попыток, по умолчанию 10
      send-try-count: 10
      # размер асинхронной очереди отправки, по умолчанию 10000
      max-queue-size: 10000

    # используется QmqTemplate для отправки сообщений по умолчанию, необязательно
    template:
      default-subject: my_default_sub

    # потребительская конфигурация, настройка пула потоков для обработки сообщений, опционально
    consumer:
      # префикс имени потока, по умолчанию qmq-process
      thread-name-prefix: my-qmq-process-
      # размер пула основных потоков, по умолчанию 2
      core-pool-size: 2
      # максимальный размер пула, по умолчанию 2
      max-pool-size: 2
      # размер очереди пула, по умолчанию 1000
      queue-capacity: 1000

    # конфигурация темы и группы сообщений, опционально
    # при использовании аннотации QmqConsumer можно использовать SpEL для введения следующих тем и групп
    subject:
      sub1: qmq_sub1
      sub2: qmq_sub2
      sub3: qmq_sub3
      # more subject ...
    group:
      group1: qmq_group1
      group2: qmq_group2
      group3: qmq_group3
      # more group ...

logging:
  level:
    # настройка уровня журнала qmq-spring-boot-starter
    xin.wjtree.qmq: trace

server:
  port: 8989

import org.junit.Test;
import org.junit.runner.RunWith;
import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.junit4.SpringRunner;
import qunar.tc.qmq.Message;
import qunar.tc.qmq.MessageSendStateListener;
import xin.wjtree.qmq.QmqTemplate;
import xin.wjtree.qmq.constant.QmqTimeUnit;
import xin.wjtree.qmq.internal.QmqAlias;
import xin.wjtree.qmq.internal.QmqIgnore;

import javax.annotation.Resource;
import java.math.BigDecimal;
import java.util.concurrent.CountDownLatch;

@RunWith(SpringRunner.class)
@SpringBootTest
public class JunitTest {
    @Resource
    private QmqTemplate template;

    @Test
    public void send() throws InterruptedException {
        // счётчик, завершение выполнения 1 раз
        CountDownLatch latch = new CountDownLatch(1);

        // использование цепочки вызовов
        template
                // тема сообщения, если не указано, будет использоваться тема по умолчанию
                .subject("sub1")
                // слушатель состояния отправки сообщения, здесь используется только для тестирования junit, если нет пользовательских требований, можно не устанавливать
                .listener(new MessageSendStateListener() {
                    @Override
                    public void onSuccess(Message m) {