@@ -0,0 +1,921 @@
+import io.jboot.Jboot;%0Aimport io.jboot.mq.JbootmqMessageListener;%0Aimport org.junit.Test;%0A%0Apublic class MqTest %7B%0A%0A    @Test%0A    public void testRedismqSend() %7B%0A        /**%0A         * jboot.properties%0A         *%0A         * jboot.mq.type= redis%0A         * jboot.mq.redis.address = 127.0.0.1:6379%0A         */%0A%0A        Jboot.getJbootmq().addMessageListener(new JbootmqMessageListener() %7B%0A            @Override%0A            public void onMessage(String channel, Object message) %7B%0A                System.out.println(%22message:%22 + message + %22     channel:%22 + channel);%0A            %7D%0A        %7D);%0A%0A        for (int i = 0; i %3C 10; i++) %7B%0A            Jboot.getJbootmq().publish(%22hello%22 + i, %22myChannel%22);%0A        %7D%0A%0A%0A        sleep(2000);%0A%0A    %7D%0A%0A%0A    private void sleep(long timeMillis) %7B%0A        try %7B%0A            Thread.sleep(timeMillis);%0A        %7D catch (InterruptedException e) %7B%0A            e.printStackTrace();%0A        %7D%0A    %7D%0A%7D%0A

add mq test