camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From TheJBoss <jbraat...@gmail.com>
Subject Re: Camel JMS Request/Reply with Websphere
Date Wed, 14 Mar 2012 03:10:28 GMT
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.

Mime
View raw message