在骆驼蓝图中设置独立的 ActiveMQ 代理 xml

Question

我正在使用 apache-camel 作为路由引擎设置一个 ServieMix 实例，我的路由定义在 blueprint.xml 中。我正在尝试为我的蓝图配置 ActiveMQ，使其与其他任何东西完全隔离（使用它自己的、私有的、代理）。

这是我的骆驼蓝图XML

<?xml version="1.0" encoding="UTF-8"?>
<blueprint 
xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0"
xmlns:cm="http://aries.apache.org/blueprint/xmlns/blueprint-cm/v1.0.0"
>

    <bean id="record_ip" class="my.service.RecordIP"/>

    <bean id="jmsConnectionFactory" 
       class="org.apache.activemq.ActiveMQConnectionFactory">
       <property name="brokerURL" value="vm://myBroker?create=true&amp;waitForStart=10000" />
       <property name="userName" value="shadow"/>
       <property name="password" value="broker"/>
    </bean>

    <bean id="pooledConnectionFactory" 
       class="org.apache.activemq.pool.PooledConnectionFactory" init-method="start" destroy-method="stop">
       <property name="maxConnections" value="8" />
       <property name="connectionFactory" ref="jmsConnectionFactory" />
    </bean>

    <bean id="jmsConfig" 
       class="org.apache.camel.component.jms.JmsConfiguration">
       <property name="connectionFactory" ref="pooledConnectionFactory"/>
       <property name="concurrentConsumers" value="10"/>
    </bean>

    <bean id="activemq" 
        class="org.apache.activemq.camel.component.ActiveMQComponent">
        <property name="configuration" ref="jmsConfig"/>
    </bean>

    <camelContext xmlns="http://camel.apache.org/schema/blueprint">

      <route id="tracing_route">
        <from uri="jetty:http://localhost:9696/trace"/>
        <inOnly uri="activemq:queue:ip_capture"/>
      </route>

      <route id="ip_capture">
        <from uri="activemq:queue:ip_capture?concurrentConsumers=1&amp;maxConcurrentConsumers=64&amp;maxMessagesPerTask=100"/>
        <bean ref="record_ip"/>
        <log message="Finished!" loggingLevel="WARN" />
      </route>
    </camelContext>

</blueprint>

我认为它根本没有使用设置，因为我收到以下错误

Could not refresh JMS Connection for destination 'ip_capture' - retrying in 5000 ms. Cause: Error while attempting to add new Connection to the pool; nested exception is javax.jms.JMSException: Could not create Transport. Reason: java.io.IOException: Broker named 'amq-broker' does not exist.

并且 amq-broker 是默认代理。

我正在尽我所能找到所有重要的东西，但缺少一些重要的东西

http://camel.apache.org/activemq.html
http://activemq.apache.org/networks-of-brokers.html
http://activemq.apache.org/how-do-i-embed-a-broker-inside-a-connection.html
http://activemq.apache.org/xml-configuration.html
我无法使用xmlns:amq="http://activemq.apache.org/schema/core"（ServiceMix无法解析）

我正在使用

ServiceMix 7.0.0
apache-camel/camel-blueprint 2.16.4
activemq-client/camel/blueprint 5.14.3

说来话长，如何正确配置 ActiveMQ 让我的蓝图与其他任何东西完全隔离？

Answer 1

我最终并没有真正需要这样做，因为就所有意图和目的而言，经纪人是独立的，设置一个新经纪人不会改变任何东西。

在骆驼蓝图中设置独立的 ActiveMQ 代理 xml

Setup independent ActiveMQ broker in camel blueprint xml

apache-camel

blueprint-osgi

camel-jms