如何使用 Apache camel / Spring-boot 订阅持久主题？

Question

每当我启动订阅者时，它都不会出现在我的 "Active Durable Topic Subscribers" 部分下的 activeMQ 上。这意味着它还不是一个持久的主题订阅者。我怎样才能让它成为持久订阅者？

JmsComponent jmsComponent = JmsComponent
        .jmsComponentTransacted(connectionFactory, jmsTransactionManager);
// TODO
jmsComponent.setClientId(subscriptionClientId);
jmsComponent.setDurableSubscriptionName(subscriptionName);
jmsComponent.setSubscriptionDurable(true); // This is enabled by default
//jmsComponent.setMaxConcurrentConsumers(maxConcurrentConsumers);
jmsComponent.setAcknowledgementMode(Session.AUTO_ACKNOWLEDGE);

return jmsComponent;

P.S：它适用于非持久订阅者。我添加了以下代码以使其持久化。我错过了什么吗？我还需要添加其他内容吗？

jmsComponent.setClientId(subscriptionClientId);
jmsComponent.setDurableSubscriptionName(subscriptionName);
jmsComponent.setSubscriptionDurable(true); // This is enabled by default

Answer 1

我通过将订阅详细信息作为查询字符串参数传递给它，如下所示；

myapp.jms.topic.inbound1=jms:topic:myFirstTopic?clientId=ABC&durableSubscriptionName=ABC

myapp.jms.topic.inbound2=jms:topic:mysecondTopic?clientId=XYZ&durableSubscriptionName=XYZ

如何使用 Apache camel / Spring-boot 订阅持久主题？

How to subscribe to a Durable TOPIC using Apache camel / Spring-boot?

java

activemq

apache-camel

spring-jms

spring-boot