    @Test
    @SneakyThrows
    public void process() {

        //为了防止交换器还没有创建
        Thread.sleep(1 * 1000);
        for (int i = 0; i < 1000; i++) {
            rabbitTemplate.convertAndSend(RabbitMQConstant.NONE_EXCHANGE, RabbitMQConstant.NONE_KEY,
                new ExampleEvent(id.getAndIncrement(), "auto message "));
        }
        Thread.sleep(100 * 1000);
    }