camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Quinn Stevenson <qu...@pronoia-solutions.com>
Subject Re: Understanding Pooled Connection Factory on ActiveMQ
Date Fri, 08 Apr 2016 16:01:13 GMT
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.

Mime
View raw message