Friday, 15 January 2010

java - Exception "Create pooled connection during start failed" when using two connection pools with ActiveMQ -



java - Exception "Create pooled connection during start failed" when using two connection pools with ActiveMQ -

so utilize case this: have set of camel (2.14) routes, polls couple of info base of operations tables, transformations , puts messages on different activemq (5.10.0) queues. i've set connection pool described in camel wiki:

<!-- activemq connection pooling--> <bean id="pooledconnectionfactory" class="org.apache.activemq.pool.pooledconnectionfactory" init-method="start" destroy-method="stop"> <property name="maxconnections" value="8" /> <property name="connectionfactory" ref="activemqconnectionfactory" /> </bean> <bean id="activemqconfig" class="org.apache.camel.component.jms.jmsconfiguration"> <property name="connectionfactory" ref="pooledconnectionfactory"/> <property name="concurrentconsumers" value="10"/> </bean> <bean id="activemq" class="org.apache.activemq.camel.component.activemqcomponent"> <property name="configuration" ref="activemqconfig"/> </bean>

i'm developing additional set of camel components, fetch info of activemq queues, , force messages forwards jms topics. these topics based on oracleaq, , current setup this:

<!-- aq jms --> <bean id="connectionfactoryoracleaq" class="oracle.jms.aqjmsfactory" factory-method="getqueueconnectionfactory"> <constructor-arg index="0"> <value>${rib.host}</value> </constructor-arg> <constructor-arg index="1" type="java.lang.string"> <value>${rib.sid}</value> </constructor-arg> <constructor-arg index="2" type="int"> <value>${rib.port}</value> </constructor-arg> <constructor-arg index="3"> <value>${rib.drivertype}</value> </constructor-arg> </bean> <bean id="credentials" class="org.springframework.jms.connection.usercredentialsconnectionfactoryadapter"> <property name="targetconnectionfactory"> <ref bean="connectionfactoryoracleaq"/> </property> <property name="username"> <value>${aq.user}</value> </property> <property name="password"> <value>${aq.pass}</value> </property> </bean> <bean id="jms" class="org.apache.activemq.camel.component.activemqcomponent"> <property name="connectionfactory" ref="credentials"/> </bean>

unfortunately sending oracleaq painfully slow. to() step in camel routes takes 2,5 seconds, not enough. thought i'd set sec connection pool see if things improved, changed setup connection mill this::

<!-- aq jms --> <bean id="connectionfactoryoracleaq" class="oracle.jms.aqjmsfactory" factory-method="getqueueconnectionfactory"> <constructor-arg index="0"> <value>${rib.host}</value> </constructor-arg> <constructor-arg index="1" type="java.lang.string"> <value>${rib.sid}</value> </constructor-arg> <constructor-arg index="2" type="int"> <value>${rib.port}</value> </constructor-arg> <constructor-arg index="3"> <value>${rib.drivertype}</value> </constructor-arg> </bean> <bean id="credentials" class="org.springframework.jms.connection.usercredentialsconnectionfactoryadapter"> <property name="targetconnectionfactory"> <ref bean="connectionfactoryoracleaq"/> </property> <property name="username"> <value>${aq.user}</value> </property> <property name="password"> <value>${aq.pass}</value> </property> </bean> <!-- activemq connection pooling aq --> <bean id="pooledconnectionfactoryaq" class="org.apache.activemq.pool.pooledconnectionfactory" init-method="start" destroy-method="stop"> <property name="maxconnections" value="8" /> <property name="connectionfactory" ref="credentials" /> </bean> <bean id="activemqconfigaq" class="org.apache.camel.component.jms.jmsconfiguration"> <property name="connectionfactory" ref="pooledconnectionfactoryaq"/> <property name="concurrentconsumers" value="10"/> </bean> <bean id="activemqaq" class="org.apache.activemq.camel.component.activemqcomponent"> <property name="configuration" ref="activemqconfigaq"/> </bean>

however when starting routes activemq, i'm seeing exception below. i'm doing wrong here? log says exception ignored, don't sense ignoring without atleast understanding why it's beingness thrown:

2014-10-09 20:50:43,783 | info | connector vm://localhost started | org.apache.activemq.broker.transportconnector | wrappersimpleappmain 2014-10-09 20:50:44,760 | warn | create pooled connection during start failed. exception ignored. | org.apache.activemq.jms.pool.pooledconnectionfactory | wrappersimpleappmain javax.jms.jmsexception: error while attempting add together new connection pool @ org.apache.activemq.jms.pool.pooledconnectionfactory.createjmsexception(pooledconnectionfactory.java:247)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.activemq.jms.pool.pooledconnectionfactory.createconnection(pooledconnectionfactory.java:202)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.activemq.jms.pool.pooledconnectionfactory.createconnection(pooledconnectionfactory.java:181)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.activemq.jms.pool.pooledconnectionfactory.start(pooledconnectionfactory.java:267)[integration-routes-1.0-jar-with-dependencies.jar:] @ sun.reflect.nativemethodaccessorimpl.invoke0(native method)[:1.7.0_45] @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:57)[:1.7.0_45] @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43)[:1.7.0_45] @ java.lang.reflect.method.invoke(method.java:606)[:1.7.0_45] @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.invokecustominitmethod(abstractautowirecapablebeanfactory.java:1640)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.invokeinitmethods(abstractautowirecapablebeanfactory.java:1581)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.initializebean(abstractautowirecapablebeanfactory.java:1511)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.docreatebean(abstractautowirecapablebeanfactory.java:521)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractautowirecapablebeanfactory.createbean(abstractautowirecapablebeanfactory.java:458)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractbeanfactory$1.getobject(abstractbeanfactory.java:293)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.defaultsingletonbeanregistry.getsingleton(defaultsingletonbeanregistry.java:223)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractbeanfactory.dogetbean(abstractbeanfactory.java:290)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.abstractbeanfactory.getbean(abstractbeanfactory.java:191)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.beans.factory.support.defaultlistablebeanfactory.preinstantiatesingletons(defaultlistablebeanfactory.java:636)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.context.support.abstractapplicationcontext.finishbeanfactoryinitialization(abstractapplicationcontext.java:934)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.springframework.context.support.abstractapplicationcontext.refresh(abstractapplicationcontext.java:479)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.xbean.spring.context.resourcexmlapplicationcontext.<init>(resourcexmlapplicationcontext.java:64)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.xbean.spring.context.resourcexmlapplicationcontext.<init>(resourcexmlapplicationcontext.java:52)[integration-routes-1.0-jar-with-dependencies.jar:] @ org.apache.activemq.xbean.xbeanbrokerfactory$1.<init>(xbeanbrokerfactory.java:104)[activemq-spring-5.10.0.jar:5.10.0] @ org.apache.activemq.xbean.xbeanbrokerfactory.createapplicationcontext(xbeanbrokerfactory.java:104)[activemq-spring-5.10.0.jar:5.10.0] @ org.apache.activemq.xbean.xbeanbrokerfactory.createbroker(xbeanbrokerfactory.java:67)[activemq-spring-5.10.0.jar:5.10.0] @ org.apache.activemq.broker.brokerfactory.createbroker(brokerfactory.java:71)[activemq-broker-5.10.0.jar:5.10.0] @ org.apache.activemq.broker.brokerfactory.createbroker(brokerfactory.java:54)[activemq-broker-5.10.0.jar:5.10.0] @ org.apache.activemq.console.command.startcommand.runtask(startcommand.java:87)[activemq-console-5.10.0.jar:5.10.0] @ org.apache.activemq.console.command.abstractcommand.execute(abstractcommand.java:57)[activemq-console-5.10.0.jar:5.10.0] @ org.apache.activemq.console.command.shellcommand.runtask(shellcommand.java:150)[activemq-console-5.10.0.jar:5.10.0] @ org.apache.activemq.console.command.abstractcommand.execute(abstractcommand.java:57)[activemq-console-5.10.0.jar:5.10.0] @ org.apache.activemq.console.command.shellcommand.main(shellcommand.java:104)[activemq-console-5.10.0.jar:5.10.0] @ sun.reflect.nativemethodaccessorimpl.invoke0(native method)[:1.7.0_45] @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:57)[:1.7.0_45] @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43)[:1.7.0_45] @ java.lang.reflect.method.invoke(method.java:606)[:1.7.0_45] @ org.apache.activemq.console.main.runtaskclass(main.java:262)[activemq.jar:5.10.0] @ org.apache.activemq.console.main.main(main.java:115)[activemq.jar:5.10.0] @ sun.reflect.nativemethodaccessorimpl.invoke0(native method)[:1.7.0_45] @ sun.reflect.nativemethodaccessorimpl.invoke(nativemethodaccessorimpl.java:57)[:1.7.0_45] @ sun.reflect.delegatingmethodaccessorimpl.invoke(delegatingmethodaccessorimpl.java:43)[:1.7.0_45] @ java.lang.reflect.method.invoke(method.java:606)[:1.7.0_45] @ org.tanukisoftware.wrapper.wrappersimpleapp.run(wrappersimpleapp.java:240)[wrapper.jar:3.2.3] @ java.lang.thread.run(thread.java:744)[:1.7.0_45]

java exception apache-camel activemq

No comments:

Post a Comment