骆驼vs ActiveMQ中的死信队列？

Question

我正在使用死信频道EIP与骆驼文件中描述的死信频道完全相同。这是我的camel.xml（删除头）

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

            <!-- this is the Dead Letter Channel error handler, where we send failed message to a log endpoint -->




    <route  errorHandlerRef="myDeadLetterErrorHandler">

        <from uri="jms:q1" />
                    <doTry>
                            <validate><simple>${body[subsc]} regex '[a-z0-9]{8}' </simple> </validate>
                            <choice>
                                    <when>
                                            <simple>${body[key1]} regex '^(v1)$'</simple>
                                            <choice>
                                                <when>
                                                       <simple>${body[key2]} == 'v2'</simple>
                                                           <to uri="jms:getInfo" />
                                                 </when>
                                            </choice>        
                                    </when>
                                    <otherwise>
                                    <to uri="jms:invalid" />
                                    <stop />
                                    </otherwise>
                            </choice>
                    <doCatch>
                            <exception>org.apache.camel.ValidationException</exception>
                            <to uri="jms:invalid"/>
                    </doCatch>
                    </doTry>

    </route>

    <route>
        <from uri="jms:queue:deadlc" />
        <log message="Got ${body}" loggingLevel="ERROR" logName="cool" />
    </route>

</camelContext>

<!--
   Lets configure some Camel endpoints

   http://camel.apache.org/components.html
-->

<!-- configure the camel activemq component to use the current broker -->

<bean id="confact" class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="vm://amq-broker?create=false"/>
        <property name="userName" value="${activemq.username}"/>
        <property name="password" value="${activemq.password}"/>
</bean>

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

</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="confact" />
     <property name="expiryTimeout" value="-1" />  
    <property name="idleTimeout" value="-1" />
</bean>

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

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


<bean id="myDeadLetterErrorHandler" class="org.apache.camel.builder.DeadLetterChannelBuilder">
        <property name="deadLetterUri" value="jms:queue:deadlc"/>
        <property name="redeliveryPolicy" ref="myRedeliveryPolicyConfig"/>
    </bean>

    <bean id="myRedeliveryPolicyConfig" class="org.apache.camel.processor.RedeliveryPolicy">
        <property name="maximumRedeliveries" value="3"/>
        <property name="redeliveryDelay" value="5000"/>
    </bean>

我只有一条路由具有基于内容的路由器，其实质是，如果消息体具有getInfo，则从jms：foo路由到jms：getInfo，如果消息体具有performAction，则从jms.foo路由到jms：performAction

我预计，当jms：getInfo使用者没有运行时，交付将失败，重新交付尝试将与spring XML中指定的一样。但是没有任何事情发生，也没有任何事情进入死信队列，相反，activemq抛出异常，如下所示。

有人能解释一下为什么它不起作用吗？我的理解是，当使用者（它是将从基于内容的路由器接收消息的目的地）未运行时，acivemq知道它甚至不应该传递消息，并且应该立即抛出一个异常，然后按照配置由camel的死信通道处理。

我使用的是camel 2.10.3和activemq 5.8.0。

我怀疑activemq正在处理失败的消息传递，忽略死信队列的骆驼xml配置，因为这些失败的消息显示在activemq web控制台中的activemq.dlq中。如果使用者正在运行，那么消息将根据camel.xml中指定的路由成功传递。

Answer 1

您的JMS消息具有replyTo=temp-queue:/id:myhost-57639-1382233787365-3:3:6。骆驼期望收到回复消息，这就是为什么你会得到20000毫秒的超时。