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);
}
}
}
結果