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

3005 ワード

複数のキューとトピックの同時送受信コードのテスト
@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);
}
}

}

結果