ActiveMQ請求 - 回覆超時

Question

我有這個activeMQ問題，我發送請求到遠程代理（來自駱駝應用程序）。請參見下面的配置：

<bean id="providerJMSConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="alwaysSessionAsync" value="false"/> 
    <property name="alwaysSyncSend" value="true"/> 
    <property name="brokerURL"><value>${remote-broker-url}</value></property> 
    <property name="clientID" value=""/> 
    <property name="closeTimeout" value="150000"/> 
    <property name="copyMessageOnSend" value="true"/> 
    <property name="disableTimeStampsByDefault" value="false"/> 
    <property name="dispatchAsync" value="false"/> 
    <property name="objectMessageSerializationDefered" value="false"/> 
    <property name="optimizeAcknowledge" value="true"/> 
    <property name="optimizedMessageDispatch" value="true"/> 
    <property name="password" value=""/> 
    <property name="producerWindowSize" value="0"/> 
    <property name="statsEnabled" value="false"/> 
    <property name="useAsyncSend" value="false"/> 
    <property name="useCompression" value="false"/> 
    <property name="useRetroactiveConsumer" value="false"/> 
    <property name="userName" value=""/> 
    <property name="watchTopicAdvisories" value="true"/> 
    <property name="sendTimeout" value="0"/> 
</bean> 

<bean id="aeroProviderJMSConfig" class="org.apache.camel.component.jms.JmsConfiguration"> 
    <property name="connectionFactory" ref="providerJMSConnectionFactory"/> 
    <property name="deliveryPersistent" value="true"/> 
    <property name="explicitQosEnabled" value="true"/>  
    <property name="priority" value="${jms-message-priority}"/> 
    <property name="acceptMessagesWhileStopping" value="false"/>  
</bean> 
<bean id="providerJMS" class="org.apache.camel.component.jms.JmsComponent"> 
    <property name="configuration" ref="providerJMSConfig"/>   
</bean> 

<osgi:camelContext xmlns="http://camel.apache.org/schema/spring" trace="true"> 
    <endpoint id="providerEndpoint" uri="providerJMS:queue:provider?replyTo=providerResponse&requestTimeout=120000"/> 
     <route> 
    <from .....> 
    <to ref="providerEndpoint"/> 
    .... 
    </route> 

每當我檢查遠程代理的「提供商響應」隊列中，我意識到resposne郵件永遠不會回升。它仍然在消息中，即使我已經要求響應消息在那裏排隊（實際上已經完成）。

我的問題是，爲什麼駱駝會拒絕從這個隊列中得到這個消息？ 請注意，Exchange模式已明確設置爲InOut。

我注意到它說CorrelationID是不一樣的，即使我檢查JMSCorrelationID的請求和對我來說看起來相同的響應。

是否有替代選擇器可用於匹配JMS請求/回覆響應？

Answer 1

而不是使用<to ref="providerEndpoint"/>嘗試<inOut ref="providerEndpoint"/>。如果您忽略URI上的replyTo參數，Camel將創建僅用於該響應的臨時隊列。