Re: Understanding Pooled Connection Factory on ActiveMQ

[Quinn Stevenson]

Sorry Michele - I missed the configuration in the jmsConfig bean.  Also, I
should've looked at the screenshot you posted - it shows the 10 consumers,
with only one consuming.  

I ran you're JMS config with a simple consuming route, but I'm seeing all of
the consumers working - I don't get any inactive consumers.  I'm using the
ActiveMQ Management console to look at this.

Here's the route I ran and I'll post a screenshot of my ActiveMQ console

<?xml version="1.0" encoding="UTF-8"?>
<blueprint xmlns="http://www.osgi.org/xmlns/blueprint/v1.0.0";
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance";
           xmlns:camel="http://camel.apache.org/schema/blueprint";
           xsi:schemaLocation="
         http://www.osgi.org/xmlns/blueprint/v1.0.0
http://www.osgi.org/xmlns/blueprint/v1.0.0/blueprint.xsd
         http://camel.apache.org/schema/blueprint
http://camel.apache.org/schema/blueprint/camel-blueprint.xsd";>

    <bean id="jmsConnectionFactory"
class="org.apache.activemq.ActiveMQConnectionFactory">
        <property name="brokerURL" value="tcp://localhost:61616"/>
        <property name="userName" value="admin" />
        <property name="password" value="admin" />
    </bean>

    <bean id="pooledConnectionFactory"
class="org.apache.activemq.pool.PooledConnectionFactory"
          init-method="start" destroy-method="stop">
        <property name="maxConnections" value="8"/>
        <property name="connectionFactory" ref="jmsConnectionFactory"/>
    </bean>

    <bean id="jmsConfig"
class="org.apache.camel.component.jms.JmsConfiguration">
        <property name="connectionFactory" ref="pooledConnectionFactory"/>
        <property name="concurrentConsumers" value="10"/>
    </bean>

    <bean id="my-amq"
class="org.apache.activemq.camel.component.ActiveMQComponent">
        <property name="configuration" ref="jmsConfig"/>
    </bean>

    <camel:camelContext id="michele-context"
xmlns="http://camel.apache.org/schema/blueprint";>
        <route id="ProcessTicket_Route">
            <from
uri="my-amq://queue:incomingTickets?destination.consumer.prefetchSize=0"/>
            <throttle timePeriodMillis="1000" asyncDelayed="true">
                <constant>1</constant>
                <to uri="mock://result" />
            </throttle>
        </route>
    </camel:camelContext>


</blueprint>






--
View this message in context: 
http://camel.465427.n5.nabble.com/Understanding-Pooled-Connection-Factory-on-ActiveMQ-tp5780689p5780779.html
Sent from the Camel - Users mailing list archive at Nabble.com.