我想知道如何将 JMS 消息同时发布到不同的主题。
示例: 1 个线程将 JMS 消息发布到主题 X, 1 个线程定期向主题 Y 发布 JMS 消息(假设每 5 秒一次)
怎样才能做到这一点?
目前使用 Wildfly 8.3 (Hornetq) 作为 JMS 提供者。
我想知道如何将 JMS 消息同时发布到不同的主题。
示例: 1 个线程将 JMS 消息发布到主题 X, 1 个线程定期向主题 Y 发布 JMS 消息(假设每 5 秒一次)
怎样才能做到这一点?
目前使用 Wildfly 8.3 (Hornetq) 作为 JMS 提供者。
一个简单的解决方案是使用 Java 的 ScheduledExecutorService
,例如:
ScheduledExecutorService ses = new ScheduledThreadPoolExecutor(2);
ses.scheduleWithFixedDelay(() -> sendJmsMessage(topicX),5,TimeUnit.SECONDS);
ses.scheduleWithFixedDelay(() -> sendJmsMessage(topicY),TimeUnit.SECONDS);