在 Camel 中为 ActiveMQ 代理配置 AMQP 传输连接器答案

【问题标题】：Configuring AMQP transport connector for ActiveMQ broker in Camel在 Camel 中为 ActiveMQ 代理配置 AMQP 传输连接器
【发布时间】：2013-07-11 22:52:00
【问题描述】：

我想要实现的目标是从 Apache Camel 的 ActiveMQ 代理启动 AMQP 协议侦听。

我确实从 org.apache.camel.archetypes:camel-archetype-activemq (Creates a new Camel project that configures and interacts with ActiveMQ.) 原型创建了 maven 模块，mvn camel:run 并成功了。然后在我对 amqp 协议进行了更改之后：

<!-- This creates an embedded ActiveMQ Broker -->
<broker xmlns="http://activemq.apache.org/schema/core" useJmx="true" persistent="false">
  <transportConnectors>
    <transportConnector name="default" uri="tcp://localhost:61616" />
    <transportConnector name="amqp+nio" uri="amqp+nio://localhost:5672"/>
  </transportConnectors>
</broker>

现在当我启动骆驼时，我得到以下异常：

Listening for connections at: tcp://localhost:61616
Connector default Started
ERROR Failed to start Apache ActiveMQ. Reason: java.io.IOException: 
   Transport Connector could not be registered in JMX: 
       Transport scheme NOT recognized: [amqp+nio]

【问题讨论】：

标签： activemq apache-camel amqp

【解决方案1】：

该原型设置了一组基本的 ActiveMQ 依赖项以启动最小代理。您还需要包括

<dependency>
  <groupId>org.apache.activemq</groupId>
  <artifactId>activemq-amqp</artifactId>
  <version>5.8.0</version>
</dependency>

公开 AMQP 传输连接器。

【讨论】：