Sorry Everyone - I missed that when reading the configs.
Thanks for pointing that out Tim - the configuration does look right.
> On Apr 7, 2016, at 10:00 PM, Tim Bain <tb...@alumni.duke.edu> wrote:
>
> Although I've only used the string-based syntax (e.g.
> from("jms:MyQueue?concurrentConsumers=10") ) to specify the number of
> concurrent consumers when I've used Camel, I assumed that <property
> name="concurrentConsumers" value="10"/> specified in the XML DSL would have
> the same effect.
>
> On Thu, Apr 7, 2016 at 9:21 AM, Quinn Stevenson <qu...@pronoia-solutions.com
>> wrote:
>
>> Looking at the Camel route, I only see once consumer on the queue - am I
>> missing something?
>>
>>
>>
>>> On 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.
>>
>>
