Details
Description
Blueprint:
<cm:property-placeholder persistent-id=".." update-strategy="reload" /> <bean id="pooledConnectionFactory" class="org.apache.activemq.jms.pool.PooledConnectionFactory" init-method="start" destroy-method="stop"> ... </bean>
or Java:
org.apache.activemq.jms.pool.PooledConnectionFactory pcf = new org.apache.activemq.jms.pool.PooledConnectionFactory(); pcf.start(); ... pcf.stop(); pcf.start(); // producer.send(textMsg);
Stacktrace:
Caused by: javax.jms.IllegalStateException: java.lang.IllegalStateException: Pool not open at org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:159) at org.apache.activemq.jms.pool.PooledConnection.createSession(PooledConnection.java:167) at org.talend.ipaas.rt.amqsource.AMQEventSource.createJmsSession(AMQEventSource.java:282) at org.talend.ipaas.rt.amqsource.AMQEventSource.sendEvent(AMQEventSource.java:117) ... 2 more Caused by: java.lang.IllegalStateException: Pool not open at org.apache.commons.pool2.impl.BaseGenericObjectPool.assertOpen(BaseGenericObjectPool.java:672) at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:339) at org.apache.commons.pool2.impl.GenericKeyedObjectPool.borrowObject(GenericKeyedObjectPool.java:279) at org.apache.activemq.jms.pool.ConnectionPool.createSession(ConnectionPool.java:141) ... 5 more