ServiceMix配置AMQP持久订阅报错，如何解决？

你遇到的错误已经把原因说得很直白了：持久订阅（Durable Subscription）是JMS Topic（发布订阅模型）专属的特性，不能用在Queue（点对点模型）上。

先理清核心概念： #

• JMS Queue是点对点模型：消息一旦被某个消费者接收，就会从队列中移除；只要消息没被确认消费，哪怕消费者宕机重启，依然能收到未处理的消息——这是Queue的默认特性，根本不需要额外配置持久订阅。
• JMS Topic是发布订阅模型：默认情况下，只有在线的订阅者能收到消息，离线期间的消息会直接丢弃；持久订阅就是为了解决这个问题，让订阅者离线后，重启时能收到这段时间内发布的消息，但它只能作用在Topic上。

针对你的需求，分两种情况处理： #

情况1：你只是想保证Queue消息不丢失（原需求）

那你完全不需要加clientId和durableSubscriptionName这些参数，回到你最初能正常运行的配置就可以。Queue本身已经具备消息持久化和故障恢复的能力，只要消费端正常完成消息确认（Camel默认是自动确认，除非你有特殊需求修改确认模式），ServiceMix宕机重启后自然能收到未消费的消息。

情况2：你确实需要使用Topic的持久订阅

那你需要把URI中的queue改成topic，调整后的路由配置应该是这样：

<route>
  <from uri="amqp:topic:///topic-1?clientId=1&amp;durableSubscriptionName=bar1" />
  <to uri="kubeActivemq:queue:///local-queue" />
</route>

同时要注意两个关键点：

• clientId必须全局唯一，同一个Broker下不能有多个持久订阅者使用相同的clientId
• clientId + durableSubscriptionName的组合必须唯一，这是Broker识别持久订阅的标识

另外你问到“难道topic名称应该和队列名称一致吗？”——完全不需要，Topic和Queue是Broker上独立的两种消息资源，名称可以完全不同，关键是要匹配你实际要订阅的消息源类型。

内容的提问来源于stack exchange，提问作者user4889345