तो नीचे मैं ऊंट (स्प्रिंग डीएसएल के माध्यम से) सफलतापूर्वक ActiveMQ कतारों के साथ अपने सेम को एकीकृत है:ऊंट मार्ग से ActiveMQ पर सॉकेट टाइमआउट लागू करें?
<!-- Note: this code is just a snippet; if you need to see more, please let me know! -->
<camelContext id="my-camel-context" xmlns="http://camel.apache.org/schema/spring">
<route>
<from uri="activemq-myinstance:queue:myqueue" />
<onException>
<exception>java.lang.Exception</exception>
<redeliveryPolicy maximumRedeliveries="2" />
<to uri="activemq-myinstance:queue_failures" />
</onException>
<to uri="bean:myBean?method=doCommand" />
</route>
</camelContext>
<bean id="jmsConnectionFactory-myqueue" class="org.apache.activemq.ActiveMQConnectionFactory">
<property name="brokerURL" value="${activemq.instance.url}" />
</bean>
<bean id="pooledConnectionFactory-myqueue" class="org.apache.activemq.pool.PooledConnectionFactory">
<property name="maxConnections" value="64" />
<property name="maximumActive" value="${max.active.consumers}" />
<property name="connectionFactory" ref="jmsConnectionFactory-myqueue" />
</bean>
<bean id="jmsConfig-myqueue" class="org.apache.camel.component.jms.JmsConfiguration">
<property name="connectionFactory" ref="pooledConnectionFactory-myqueue"/>
<property name="concurrentConsumers" value="${max.active.consumers}"/>
</bean>
<bean id="activemq-myqueue" class="org.apache.activemq.camel.component.ActiveMQComponent">
<property name="configuration" ref="jmsConfig-myqueue"/>
</bean>
मैं स्पष्ट रूप से एक सॉकेट टाइमआउट (Socket.read() पर) को लागू करना चाहते हैं - के बीच ऊंट और ActiveMQ - की 25 सेकंड इस प्रकार, जब कैमल ActiveMQ से/से संदेश को रूट करने का प्रयास करता है, यदि ActiveMQ को उस प्रतिक्रिया को पूरा करने के लिए 25 सेकंड से अधिक समय लगता है, तो मैं थ्रेड को शानदार तरीके से बाहर निकलना चाहता हूं। जाहिर है, अगर किसी प्रकार का फेलओवर भी स्थापित करना संभव है (ताकि अनुरोध है कि समय-समय पर उस समय के समय को फिर से चलाया जा सके) जो संदेश को खोने पर बहुत पसंद है!
मैं यह कैसे पूरा कर सकते हैं? अग्रिम में धन्यवाद!
अद्यतन: अगर कैमल/JMS/ActiveMQ बॉक्स से बाहर इस का समर्थन नहीं करता, मैं लिख कोई आपत्ति नहीं है मेरे अपने "ThreadManager" कि व्यवधान/25-सेकंड के बाद बंद हो जाता है धागे, लेकिन मैं नहीं कर रहा हूँ सुनिश्चित करें कि इंटरफ़ेस/कक्षाओं को कार्यान्वित/विस्तारित करने के लिए, और बाद में मेरे वसंत सेम में तार।
शायद अगर मैंने अपने 'PooledConnectionFactory' पर 'expiryTimeout' सेट किया है? – IAmYourFaja