All: I have been trying to take advantage of the InOut pattern over JMS. I am using Camel 2.4.0 and ActiveMQ 5.3.1
I have created a simple example that can be run to replicate the problem I am
experiencing. Attached please find the source code plus ant build file. Within
the libs folder is a file listing all required jars (sorry - I wasn't sure
about uploading a 30M file to this list!).
Once you have the necessary jars in place under libs/compile then in two
terminal windows:
ant clean run-consumer
ant run-publisher
The consumer implements the InOut processor and the publisher invokes it over
JMS.
Within the second terminal window you will soon see
[java] Caused by: org.apache.camel.ExchangeTimedOutException: The OUT message
was not received within: 20000 millis. Exchange[Message: John]
[java] at
org.apache.camel.component.jms.JmsProducer.processInOut(JmsProducer.java:265)
[java] at
org.apache.camel.component.jms.JmsProducer.process(JmsProducer.java:147)
Originally I had specified 5 consumers in the
metadata/test-env/res/applicationContext-consumer.xml file. However, I can set
the number of consumers down to one and the same problem occurs. BTW, we use a
clustered environment - so I would like to specify multiple consumers and use
multiple computers.
Any insight into this would be greatly appreciated!!
TIA,
Mike L. (aka patzerbud)
Camel-InOut.tar.gz
Description: GNU Zip compressed data
