2010-12-14 125 views
2

我試圖發送請求/回覆消息給駱駝的遠程代理,但它超時。請參閱下面的配置:駱駝JMS請求/回覆超時

<bean id="providerJMSConnectionFactory" class="org.apache.activemq.ActiveMQConnectionFactory"> 
    <property name="alwaysSessionAsync" value="false"/> 
    <property name="alwaysSyncSend" value="true"/> 
    <property name="brokerURL"><value>${remote-broker-broker-url}</value></property> 
    <property name="clientID" value=""/> 
    <property name="closeTimeout" value="15000"/> 
    <property name="copyMessageOnSend" value="true"/> 
    <property name="disableTimeStampsByDefault" value="false"/> 
    <property name="dispatchAsync" value="false"/> 
    <property name="objectMessageSerializationDefered" value="false"/> 
    <property name="optimizeAcknowledge" value="false"/> 
    <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="providerJMSConfig" class="org.apache.camel.component.jms.JmsConfiguration"> 
    <property name="connectionFactory" ref="aeroProviderJMSConnectionFactory"/> 
    <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="aeroProviderJMSConfig"/> 
</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> 
<osgi:camelContext> 

這是爲什麼發生?我意識到,在遠程經紀人中,消費者的數量總是超過1,儘管我沒有指定應該擁有多少消費者。另外,當我刪除replyTo目標時,名稱仍然在遠程代理上繼續顯示。

請問,是否有任何工具可以用來調試activemq,以便我可以看到誰正在從隊列中選擇消息?

回答

2

當通過Camel的JMS請求/回覆時,它使用20秒的默認超時。你打的超時了嗎?

您可以改變它,它的requestTimeout選項 http://camel.apache.org/jms