Does increasing your prefetch buffer size as described in http://activemq.2283324.n4.nabble.com/Concurrent-consumers-td3041439.html resolve the problem?
Tim On Thu, Apr 7, 2016 at 4:17 AM, Michele <michele.mazzi...@finconsgroup.com> wrote: > 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. >
