camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Claus Ibsen <claus.ib...@gmail.com>
Subject Re: Camel JMS Request/Reply with Websphere
Date Wed, 14 Mar 2012 08:49:08 GMT
Hi

If you use Camel 2.9 then I suggest to take a look at the replyToType
option. And if your reply queue is only used by this application, then
you can configure the replyToType=Exclusive. This avoids using JMS
message selectors for the correlation task, which otherwise would have
to creates new consumers to pickup JMS message selector changes, as
you cannot adjust a JMS message selector on an existing JMS consumer.

And you may take a look at tweaking the cache options as well.



On Wed, Mar 14, 2012 at 4:10 AM, TheJBoss <jbraathen@gmail.com> wrote:
> Hello, I am hoping that someone would be able to point out a misconfiguration
> or something that needs to be added.  I am working on a WAS7/MQ6 project
> that ties a synchronous HTTP/SOAP service to a asynchronous IBM Websphere MQ
> request/reply for purposes of exposing a mainframe transaction
> synchronously.  The service seems to be functioning fine and as expected,
> however a few minutes after running a 10-concurrent load against the
> application I see the following exception in the logs:
>
> W   [:] CWSJY0003W: JMSCC3034: The exception is ignored as no exception
> listener is registered: '
>                       Message :
> com.ibm.msg.client.jms.DetailedJMSException: JMSWMQ1107: A problem with this
> connection has occurred. An error has occurred with the WebSphere MQ JMS
> connection. Use the linked exception to determine the cause of this error.
>                         Class : class
> com.ibm.msg.client.jms.DetailedJMSException
>                         Stack :
> com.ibm.msg.client.wmq.common.internal.Reason.reasonToException(Reason.java:608)
>
>
> Futher analysis of the logs it appears that the ConnectionFactory/Connection
> is not being handled correctly, either the connections are being closed and
> they shouldn't be or they are not being closed and they should be???
>
> I'll toss a Starbucks gift card out there for some expert advice.
>
> Thanks in advance!
>
> ~Justin
>
>
>
> <beans xmlns="http://www.springframework.org/schema/beans"
> xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> xmlns:camel="http://camel.apache.org/schema/spring"
> xmlns:jee="http://www.springframework.org/schema/jee"
>        xsi:schemaLocation="http://www.springframework.org/schema/beans
>        http://www.springframework.org/schema/beans/spring-beans.xsd
>        http://camel.apache.org/schema/spring
>        http://camel.apache.org/schema/spring/camel-spring.xsd
>        http://www.springframework.org/schema/jee
> http://www.springframework.org/schema/jee/spring-jee-3.0.xsd ">
>
>        <bean id="mQDestinationResolver" class="com.my.MQDestinationResolver" />
>
>
>
>        <jee:jndi-lookup id="connectionFactoryJndi"
> jndi-name="jms.ConnectionFactoryRef" />
>
>
>        <bean id="jms" class="org.apache.camel.component.jms.JmsComponent">
>                <property name="connectionFactory" ref="connectionFactoryJndi"
/>
>                <property name="destinationResolver" ref="mQDestinationResolver"
/>
>                <property name="testConnectionOnStartup" value="true" />
>                <property name="concurrentConsumers" value="1" />
>                <property name="useMessageIDAsCorrelationID" value="true" />
>                <property name="cacheLevelName" value="CACHE_NONE" />
>                <property name="cacheLevel" value="0" />
>                <property name="errorHandlerLogStackTrace" value="false" />
>
>
>                <property name="replyToCacheLevelName" value="CACHE_NONE" />
>        </bean>
>
>
>
>
>        <camelContext trace="false" useMDCLogging="true"
>                useBreadcrumb="false" xmlns="http://camel.apache.org/schema/spring">
>
>                <camel:onException>
>                        <camel:exception>java.lang.Exception</camel:exception>
>                        <camel:handled>
>                                <camel:constant>true</camel:constant>
>                        </camel:handled>
>                        <camel:process ref="defaultExceptionProcessor"
/>
>                        <camel:marshal>
>                                <camel:soapjaxb contextPath="my.jaxb.soap.annotated.package"
> encoding="UTF-8" />
>                        </camel:marshal>
>                </camel:onException>
>
>                <camel:route>
>                        <camel:from uri="servlet:///HTTPSoapEndpoint" />
>                        <camel:unmarshal>
>                                <camel:soapjaxb contextPath="my.jaxb.soap.annotated.package"
> encoding="UTF-8" />
>                        </camel:unmarshal>
>                        <camel:process ref="httpXMLRequestProcessor" />
>
>                        <camel:choice>
>                                <camel:when>
>                                        <camel:simple>${property.myBoolean}</camel:simple>
>                                        <camel:to uri="http4://SOAPURL"
/>
>                                        <camel:convertBodyTo type="java.lang.String"
/>
>                                </camel:when>
>                        </camel:choice>
>
>                        <camel:process ref="Processor1" />
>                        <camel:to uri="jms:RequestQ?replyTo=ReplyQ" pattern="InOut"
/>
>                        <camel:process ref="Processor2" />
>                        <camel:marshal>
>                                <camel:soapjaxb contextPath="my.jaxb.soap.annotated.package"
> encoding="UTF-8" />
>                        </camel:marshal>
>                </camel:route>
>
>        </camelContext>
>
> </beans>
>
>
>
> JMSXAppID=IMSJ    CUSMQS00            ,
> JMSType=null,
> JMSExpiration=1331685348768,
> JMSXGroupID=null,
> JMS_IBM_PutTime=00352903,
> JMSPriority=0,
> JMS_IBM_Encoding=785,
> JMS_IBM_Character_Set=IBM037,
> JMS_IBM_PutDate=20120314,
> JMSReplyTo=null,
> JMSCorrelationID=ID:414d51204d51545f44564a3130202020bfb2494f252ba34c,
> JMSMessageID=ID:c3e2d840d4d8e3d14040404040404040c94396fb9f26b826,
> JMSTimestamp=1331685329030,
> JMS_IBM_PutApplType=3,
> JMSXUserID=mqat        ,
> JMS_IBM_MsgType=2,
> JMSXDeliveryCount=1,
> JMSDeliveryMode=2,
> JMSDestination=null,
> JMS_IBM_Format=MQSTR   ,
> JMSRedelivered=false
>
>
>
> http://camel.465427.n5.nabble.com/file/n5563339/mqErrors.zip mqErrors.zip
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/Camel-JMS-Request-Reply-with-Websphere-tp5095847p5563339.html
> Sent from the Camel - Users mailing list archive at Nabble.com.



-- 
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
Twitter: davsclaus, fusenews
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/

Mime
View raw message