爲Camel的ActiveMQ代理配置AMQP傳輸連接器

Question

目標我試圖實現的是啓動從Apache Camel的ActiveMQ代理偵聽的AMQP協議。

我已經創建了從0​​原型創建的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] 

Answer 1

這原型建立了一套基本的ActiveMQ依賴踢啓動最小的經紀人。您還需要包含

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

以顯示AMQP傳輸連接器。