0

我正在使用 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 是默认代理。

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

我在用

  • 服务混合 7.0.0
  • 阿帕奇骆驼/骆驼蓝图 2.16.4
  • activemq-client/camel/蓝图 5.14.3

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

4

1 回答 1

0

我最终并不真正需要这样做，因为无论出于何种意图和目的，代理都是独立的，并且设置一个新代理不会改变任何事情。

于 2018-12-12T14:04:34.637 回答