camel-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Willem Jiang <willem.ji...@gmail.com>
Subject Re: AW: Problem with SOAP/JMS and transactions
Date Mon, 02 Nov 2009 13:27:13 GMT
Hi Christian,

I think it may relate to the CamelDestination just deal with input and 
output stream.
As you know if you throw the exception from the service impl, the 
exception will be caught by the CXF interceptor chain and it will be 
turned into a soap fault message, then be passed back to the client.

Since the CamelDestination can't know the under layer message is the 
fault message, it can't throw the exception to let the camel-jms 
component roll back.

Maybe we need to find another way to resolve your issue.

Willem

Schneider Christian wrote:
> Hi Willem,
> 
> I have adjusted my applicationContext but still my message gets acknowledged
> instead of being rolled back.
> 
> My service impl contains:
>   throw new RuntimeException("Test for transaction");
> 
> Any idea what still goes wrong?
> 
> Greetings
> 
> Christian
> 
> ----
> 
> My applicationcontext now looks like the following. I have also added
> <transacted/> to the route for the server.
> 
> 
> 
> <beans xmlns="http://www.springframework.org/schema/beans"
> 	xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
> 	xmlns:context="http://www.springframework.org/schema/context"
> 	xsi:schemaLocation="http://www.springframework.org/schema/beans
> http://www.springframework.org/schema/beans/spring-beans-2.0.xsd
> 		http://cxf.apache.org/core
> http://cxf.apache.org/schemas/core.xsd
> 		http://cxf.apache.org/jaxws
> http://cxf.apache.org/schemas/jaxws.xsd
> 		http://www.springframework.org/schema/context
> http://www.springframework.org/schema/context/spring-context-2.5.xsd
> 		http://camel.apache.org/schema/spring
> http://camel.apache.org/schema/spring/camel-spring.xsd
> 		http://cxf.apache.org/transports/camel
> http://cxf.apache.org/transports/camel.xsd"
> <context:annotation-config/>
> 
> 	<import resource="classpath:META-INF/cxf/cxf.xml" />
> 	<import resource="classpath:META-INF/cxf/cxf-extension-soap.xml" />
> 	<import resource="classpath:META-INF/cxf/cxf-extension-camel.xml" />
> 	<import resource="classpath:serviceRuntimeContext.xml" />
> 	
> 	<bean id="configProps"
> 	
> class="org.springframework.beans.factory.config.PropertyPlaceholderConfigure
> r">
> 		<property name="locations">
> 			<list>
> 				<value>classpath:jms.properties</value>
> 			</list>
> 		</property>
> 	</bean>
> 			
> 	<!-- Make sure to read the best practices for design and
> implementation before
> 		 developing a service for production use.
> 		 http://wissen.enbw.net/display/etgsoa/3+-+Design
> 		 http://wissen.enbw.net/display/etgsoa/4+-+Entwicklung
> 	-->
> 	<bean id="appModule" class="net.enbw.endur.AppModule">
> 		<property name="customerService" ref="customerService"/>
> 	</bean>
> 	
> 	<bean id="serviceImpl" class="net.enbw.endur.ServiceImpl">
> 	</bean>
> 
> 	<!-- SOA configs below  -->
> 	
> 	<endpoint id="customerServiceEndpoint"
> xmlns="http://cxf.apache.org/jaxws"
> 		xmlns:service="http://examples.etg.services.enbw.net/"
> 		serviceName="service:CustomerService"
> 		endpointName="service:CustomerServiceEndpoint"
> 		address="camel://direct:server"
> 		implementor="#serviceImpl">
> 		<features>
> 			<!-- Enables logging of SOAP messages. -->
> 			<logging xmlns="http://cxf.apache.org/core" /> 
> 		</features>
> 	</endpoint>
> 
> 	<client id="customerService" xmlns="http://cxf.apache.org/jaxws"
> 		xmlns:service="http://examples.etg.services.enbw.net/"
> 		serviceName="service:CustomerService"
> 		endpointName="service:CustomerServiceEndpoint"
> 	
> serviceClass="net.enbw.services.etg.examples.customerservice.CustomerService
> V1"
> 		address="camel://direct:client">
> 		<features>
> 			<!-- Enables logging of SOAP messages. -->
> 			<!-- logging xmlns="http://cxf.apache.org/core" /-->
> 		</features>
> 	</client>
> 
> 	<camelContext id="camelContext" trace="false"
> xmlns="http://camel.apache.org/schema/spring">
> 		<route>
>     		<from uri="direct:client"/>
>     		<to
> uri="jms://queue.net.enbw.services.etg.examples.customerservice.CustomerServ
> ice" />
> 		</route>
> 		<route>
>     		<from
> uri="jms://queue.net.enbw.services.etg.examples.customerservice.CustomerServ
> ice" />
>     		<transacted/>
>     		<to uri="direct:server" />
> 		</route>
> 	</camelContext>
> 
> 	<!-- See http://camel.apache.org/jms.html -->
> 	<bean id="jms"
> 		class="org.apache.camel.component.jms.JmsComponent">
> 		<constructor-arg index="0">
> 			<ref bean="jmsConfiguration" />
> 		</constructor-arg>
> 		<property name="connectionFactory"
> ref="jmsConnectionFactory" />
> 	</bean>
> 	<bean id="jmsConfiguration"
> 		class="org.apache.camel.component.jms.JmsConfiguration">
> 		<property name="useMessageIDAsCorrelationID" value="true" />
> 		<property name="acknowledgementModeName" value="TRANSACTED"
> />
> 		<property name="explicitQosEnabled" value="true" />
> 		<property name="receiveTimeout"
> value="${jms.receiveTimeout}" />
> 		<property name="requestTimeout"
> value="${jms.requestTimeout}" />
> 		<property name="recoveryInterval"
> value="${jms.recoveryInterval}" />
> 		<property name="timeToLive" value="${jms.timeToLive}" />
> 		<property name="transacted" value="true" />
> 		<property name="transactedInOut" value="true" />
> 		<property name="transactionManager"
> ref="jmsTransactionManager"/>
> 	</bean>
> 
> 	<bean id="jmsTransactionManager"
> class="org.springframework.jms.connection.JmsTransactionManager">
> 		<property name="connectionFactory"
> ref="jmsConnectionFactory" />
> 	</bean>
> 
> 	<!--  See Tibco EMS documentation  -->
> 	<bean id="jmsConnectionFactory"
> 		class="com.tibco.tibjms.TibjmsConnectionFactory">
> 		<property name="serverUrl" value="${jms.serverUrl}" />
> 		<property name="userName" value="${jms.userName}" />
> 		<property name="userPassword" value="${jms.userPassword}" />
> 		<property name="reconnAttemptCount"
> value="${jms.reconnAttemptCount}" />
> 		<property name="reconnAttemptDelay"
> value="${jms.reconnAttemptDelay}" />
> 	</bean>
> 
> </beans>
> 


Mime
View raw message