【发布时间】:2021-07-06 15:21:31
【问题描述】:
我想知道如何将 JMS 消息同时发布到不同的主题。
示例: 1个线程将JMS消息发布到主题X, 1 个线程定期向主题 Y 发布 JMS 消息(假设每 5 秒一次)
如何做到这一点?
目前使用 Wildfly 8.3 (Hornetq) 作为 JMS 提供程序。
【问题讨论】:
标签: java jms wildfly-8 hornetq jms-topic
我想知道如何将 JMS 消息同时发布到不同的主题。
示例: 1个线程将JMS消息发布到主题X, 1 个线程定期向主题 Y 发布 JMS 消息(假设每 5 秒一次)
如何做到这一点?
目前使用 Wildfly 8.3 (Hornetq) 作为 JMS 提供程序。
【问题讨论】:
标签: java jms wildfly-8 hornetq jms-topic
一个简单的解决方案是使用 Java 的 ScheduledExecutorService,例如:
ScheduledExecutorService ses = new ScheduledThreadPoolExecutor(2);
ses.scheduleWithFixedDelay(() -> sendJmsMessage(topicX), 0, 5, TimeUnit.SECONDS);
ses.scheduleWithFixedDelay(() -> sendJmsMessage(topicY), 0, 5, TimeUnit.SECONDS);
【讨论】: