Springboot統合activeMQ複数のキューとトピックの同時送受信を実現(6)

複数のキューとトピックの同時送受信コードのテスト

@Component
public class ScheduledTaskMQ {

    boolean debug=false;

    @Autowired
    QueueSender queue;

    @Autowired
    TopicSender topic;

    @Scheduled(fixedDelay=50)
    public void sendQueueTest() {
        if(debug) {
            String message = " :" + DateUtil.formatDate(new Date());
            queue.send1(message);
            queue.send2(message);
        }
    }

    @Scheduled(fixedDelay=50)
    public void sendTopicTest() {
        if(debug) {
            String message = " :" + DateUtil.formatDate(new Date());
            topic.send1(message);
            topic.send2(message);
        }
    }

}

結果