代码之家 › 专栏 › 技术社区 › user3007165

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

spring-jms activemq apache-camel spring-boot java

user3007165 · 技术社区 · 7 年前

每当我启动订阅服务器时,它都不会出现在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;

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

1 回复 | 直到 5 年前

user3007165 7 年前

我将订阅详细信息作为查询字符串参数传递给它,使其正常工作,如下所示;

myapp。jms。话题inbound1=jms:topic:myFirstTopic?客户ID=ABC&durableSubscriptionName=ABC

myapp。jms。话题inbound2=jms:topic:mysecondTopic?clientId=XYZ&durableSubscriptionName=XYZ

推荐文章

BÅaÅ¼ej Karwowski · 如何处理JmsChannelFactoryBean错误,是否有可能使用自定义错误通道?

6 年前

M06H · Java语言lang.NoClassDefFoundError发送到oracle aq时出错

6 年前

neaGaze · Tomcat无法与Artemis MQ通信

7 年前

Mohamed Hosni · 活动mq artemis springboot群集主题负载平衡(循环)问题

7 年前

toppless · 使用Java配置的Spring集成和JMS

7 年前

Prashant Kumar · JMS模板,如何使用JMS模板从一个队列接收消息并发送到另一个队列

7 年前

user3007165 · 如何使用Apache camel/Spring boot订阅持久主题?

7 年前

user1246979 · 对不同的消息类型使用aws sqs

7 年前

nkare · WebSphere liberty wasJmsServer死信队列

7 年前

Dhaval Salwala · JMS连接在向未经授权的路由发送消息时未引发JMSSecurityException

7 年前