Re: My camel route not able to handle exception.

[bhaumikananda]

Hi Willem Jiang,

I am using text message. The connection details are - 

<endpoint id="fitOptInMsgQueue" uri="wmq:myProjQueue" />
        <bean id="PROPAGATION_REQUIRED_FIT_OPTION"
class="org.apache.camel.spring.spi.SpringTransactionPolicy">
                <property name="transactionManager" ref="jmsTransactionManager" 
/>
                <property name="propagationBehaviorName" 
value="PROPAGATION_REQUIRED"/>
        </bean>
        .
        .
        <bean id="wmq" class="org.apache.camel.component.jms.JmsComponent">
                <property name="connectionFactory" 
ref="cachedConnectionFactory" />
                <property name="transactionManager" ref="jmsTransactionManager" 
/>
                <property name="transacted" value="true" />
                <property name="asyncConsumer" value="true" />
                <property name="concurrentConsumers" 
value="${mq.concurrent.consumers}" />
5
                <property name="maxConcurrentConsumers"
value="${mq.max.concurrent.consumers}"></property> 20
                <property name="errorHandlerLoggingLevel" value="ERROR" />
                <property name="errorHandlerLogStackTrace" value="false" />
        </bean>

        <bean id="jmsTransactionManager"
                
class="org.springframework.jms.connection.JmsTransactionManager">
                <property name="connectionFactory" 
ref="cachedConnectionFactory" />
        </bean>

        <bean id="cachedConnectionFactory"
                
class="org.springframework.jms.connection.CachingConnectionFactory"
                destroy-method="destroy">
                <property name="sessionCacheSize" value="50" />
                <property name="targetConnectionFactory">
                        <ref bean="queueConnectionFactory" />
                </property>
        </bean>

        <bean id="queueConnectionFactory"
class="com.ibm.mq.jms.MQQueueConnectionFactory">
                <property name="hostName" value="${mq.host.name}" />
                <property name="port" value="${mq.host.port}" />
                <property name="queueManager" value="${mq.queueManager}" />
                <property name="channel" value="${mq.channel}" />
                <property name="transportType" value="${mq.transportType}" />
                <property name="securityExit" 
value="bctoolsj.wsmqtools.exits.BCPKIJCExit"
/>
        </bean>

** Also I think it will be useful if I share the DB connection as well ** 

        <bean id="sql" class="org.apache.camel.component.sql.SqlComponent">
                <property name="dataSource" ref="myDS" />
        </bean>

        <bean id="myDS" class="org.apache.commons.dbcp.BasicDataSource"
                destroy-method="close">
                <property name="driverClassName" 
value="net.sourceforge.jtds.jdbc.Driver"
/>
                <property name="url" value="${my.db.connectionurl}" />
                <property name="username" value="${my.db.user}" />
                <property name="password" value="${my.db.pwd}" />
                <property name="testOnBorrow" value="true"/>
                <property name="validationQuery" value="SELECT 1"/>
                <property name="maxActive" value="${my.active.db.threads}"/>8
        </bean>



--
View this message in context: 
http://camel.465427.n5.nabble.com/My-camel-route-not-able-to-handle-exception-tp5739381p5739494.html
Sent from the Camel - Users mailing list archive at Nabble.com.