Hi Tim,
sorry, but I'm a bit confused.
My use case is to create a Camel Route that it is capable:
1. Read large number of lines in File (approx. 50000)
2. Split, Process and store every line in AMQ (Simple hash map)
3. Retrieve message from queue and invoke with POST a Rest Service that is
bottleneck (I need to process messages stored in AMQ slowly in order to
don't overload a Rest Service Interface).
<route id="FileReader_Route">
<from uri="file:incoming?....." />
<split streaming="true" parallelProcessing="true">
<tokenize token="\n" />
<unmarshal ref="IncomingCSVFileDataFormat" />
<process ref="DataProcessor" />
<marshal ref="Gson" />
<to uri="activemq:queue:incomingTickets" />
</split>
</route>
<route id="ProcessTicket_Route">
<from
uri="activemq:queue:incomingTickets?destination.consumer.prefetchSize=0" />
<throttle timePeriodMillis="10000" asyncDelayed="true">
<constant>5</constant>
<to
uri="jetty:http://host/rs/v1.0/ticket?jettyHttpBindingRef=CustomJettyHttpBinding";
/>
</throttle>
</route>
I don't understand well how Producer and Consumer work on the broker. My
idea is that Producer pust message in Queue and Consumer pop message from
queue to dispatch. Is it right?
So, I configured a pooled connection factory to handle efficiently
connections, sessions, producers and consumers.
As you can see bt attached picture pooled-connection.png
<http://activemq.2283324.n4.nabble.com/file/n4710461/pooled-connection.png>
, why is there only one consumer that works on Queue?
I hope i was clear.
Thanks a lot again
Kind greetings
Michele
--
View this message in context:
http://activemq.2283324.n4.nabble.com/Pooled-connection-factory-does-not-work-tp4710421p4710461.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
