On Thu, Jul 2, 2009 at 4:53 PM, Charles Moulliard<cmoulli...@gmail.com> wrote: > queueQuickFixInEndpoint is a JMS queue. > > I will add the ref to the transacted and retest > > Question : I suppose that rollback will not occur if by example JMS and DB > (=Hibernate) does not use the same TransactionManager and don't use this > spring class together : > org.springframework.transaction.PlatformTransactionManager Yes they must be configured to use the same TX manager.
> > Regards, > > Charles Moulliard > Senior Enterprise Architect > Apache Camel Committer > > ***************************** > blog : http://cmoulliard.blogspot.com > > > On Thu, Jul 2, 2009 at 4:46 PM, Claus Ibsen <claus.ib...@gmail.com> wrote: > >> Transacted also have a ref attribute >> >> <transacted ref="required"/> >> >> Is queueQuickFixInEndpoint a JMS queue? >> You need to use a TX manager that can do both JMS and DB. >> >> >> >> On Thu, Jul 2, 2009 at 4:31 PM, Charles Moulliard<cmoulli...@gmail.com> >> wrote: >> > I have been able to solve my problem by adding the following bean >> definition >> > : >> > >> > <bean id="required" >> > class="org.apache.camel.spring.spi.SpringTransactionPolicy"> >> > <property name="transactionManager"> >> > <osgi:reference >> > interface="org.springframework.transaction.PlatformTransactionManager"/> >> > </property> >> > </bean> >> > >> > and in the route >> > >> > <camel:route> >> > <camel:from ref="queueQuickFixInEndpoint" /> >> > <camel:convertBodyTo type="quickfix.Message" /> >> > <camel:transacted/> >> > <camel:policy ref="required" /> >> > <camel:bean ref="serviceHelper" method="createNotification" /> >> > <camel:bean ref="serviceHelper" method="generateError" /> >> > <camel:to ref="directNotificationEndpoint" /> >> > </camel:route> >> > >> > Unfortunately, the rollback does not occur in the DB and 6 records have >> been >> > created by the method createNotification when error has been raised by >> the >> > method generateError. >> > >> > What is missing ? >> > >> > Charles Moulliard >> > Senior Enterprise Architect >> > Apache Camel Committer >> > >> > ***************************** >> > blog : http://cmoulliard.blogspot.com >> > >> > >> > On Thu, Jul 2, 2009 at 4:19 PM, Charles Moulliard <cmoulli...@gmail.com >> >wrote: >> > >> >> When I compare the example : JMSTransactionalClientRollbackTest.xml >> >> >> >> <!-- START SNIPPET: e1 --> >> >> <!-- setup JMS connection factory --> >> >> <bean id="jmsConnectionFactory" >> >> class="org.apache.activemq.ActiveMQConnectionFactory"> >> >> <property name="brokerURL" >> >> value="vm://localhost?broker.persistent=false&broker.useJmx=false"/> >> >> </bean> >> >> >> >> <!-- setup spring jms TX manager --> >> >> <bean id="jmsTransactionManager" >> >> class="org.springframework.jms.connection.JmsTransactionManager"> >> >> <property name="connectionFactory" ref="jmsConnectionFactory"/> >> >> </bean> >> >> >> >> <!-- define our activemq component --> >> >> <bean id="activemq" >> >> class="org.apache.activemq.camel.component.ActiveMQComponent"> >> >> <property name="connectionFactory" ref="jmsConnectionFactory"/> >> >> <!-- define the jms consumer/producer as transacted --> >> >> <property name="transacted" value="true"/> >> >> <!-- setup the transaction manager to use --> >> >> <!-- if not provided then Camel will automatic use a >> >> JmsTransactionManager, however if you >> >> for instance use a JTA transaction manager then you must >> >> configure it --> >> >> <property name="transactionManager" >> ref="jmsTransactionManager"/> >> >> </bean> >> >> <!-- END SNIPPET: e1 --> >> >> >> >> <!-- START SNIPPET: e2 --> >> >> <camelContext xmlns="http://camel.apache.org/schema/spring";> >> >> <route> >> >> <!-- 1: from the jms queue --> >> >> <from uri="activemq:queue:okay"/> >> >> <!-- 2: mark this route as transacted --> >> >> <transacted/> >> >> <!-- 3: call our business logic that is myProcessor --> >> >> <process ref="myProcessor"/> >> >> <!-- 4: if success then send it to the mock --> >> >> <to uri="mock:result"/> >> >> </route> >> >> </camelContext> >> >> >> >> with mine. >> >> >> >> What is different concerns the TransactionManager used. >> >> >> >> In the example, this is the Spring one: >> >> >> >> <!-- setup spring jms TX manager --> >> >> <bean id="jmsTransactionManager" >> >> class="org.springframework.jms.connection.JmsTransactionManager"> >> >> <property name="connectionFactory" ref="jmsConnectionFactory"/> >> >> </bean> >> >> >> >> and in my case, ActiveMQ is configured to use Geronimo Transaction >> Manager >> >> bundle (which in fact uses spring Transaction manager : >> >> org.springframework.transaction.jta.JtaTransactionManager;) >> >> >> >> I suppose that in the example, the policy is defined by default by >> spring >> >> when instantiating the class : >> >> org.springframework.jms.connection.JmsTransactionManager >> >> >> >> Is it possible to do the same using a JtaTransaction manager ? >> >> >> >> Regards, >> >> >> >> Charles Moulliard >> >> Senior Enterprise Architect >> >> Apache Camel Committer >> >> >> >> ***************************** >> >> blog : http://cmoulliard.blogspot.com >> >> >> >> >> >> On Thu, Jul 2, 2009 at 3:57 PM, Claus Ibsen <claus.ib...@gmail.com> >> wrote: >> >> >> >>> Hi >> >>> >> >>> Yeah you need to add all the spring transaction stuff. >> >>> >> >>> >> >>> On Thu, Jul 2, 2009 at 3:47 PM, Charles Moulliard<cmoulli...@gmail.com >> > >> >>> wrote: >> >>> > Camel generates the following error with my route : >> >>> > >> >>> > Route >> >>> > >> >>> > <camel:route> >> >>> > <camel:from ref="queueQuickFixInEndpoint" /> >> >>> > <camel:convertBodyTo type="quickfix.Message" /> >> >>> > <camel:transacted/> >> >>> > <camel:bean ref="serviceHelper" >> method="createNotification" >> >>> /> >> >>> > <camel:bean ref="serviceHelper" method="generateError" /> >> >>> > <camel:to ref="directNotificationEndpoint" /> >> >>> > </camel:route> >> >>> > >> >>> > It seems that policy must be defined but in the example here it is >> not >> >>> > mentioned : http://camel.apache.org/transactional-client.html >> >>> > >> >>> > Error : >> >>> > >> >>> > 15:43:07,838 | ERROR | xtenderThread-30 | ContextLoaderListener >> >>> | >> >>> > BundleApplicationContextListener 50 | Application context refresh >> >>> failed >> >>> > (OsgiBundleXmlApplicationContext(bundle=com.xpectis.x3s.x3s-core, >> >>> > config=osgibundle:/META-INF/spring/*.xml)) >> >>> > org.apache.camel.RuntimeCamelException: >> >>> java.lang.IllegalArgumentException: >> >>> > policy must be specified on: Transacted[ref: null] >> >>> > at >> >>> > >> >>> >> org.apache.camel.util.ObjectHelper.wrapRuntimeCamelException(ObjectHelper.java:986) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:121) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.CamelContextFactoryBean.onApplicationEvent(CamelContextFactoryBean.java:465) >> >>> > at >> >>> > >> >>> >> org.springframework.context.event.SimpleApplicationEventMulticaster$1.run(SimpleApplicationEventMulticaster.java:78) >> >>> > at >> >>> > >> >>> >> org.springframework.core.task.SyncTaskExecutor.execute(SyncTaskExecutor.java:49) >> >>> > at >> >>> > >> >>> >> org.springframework.context.event.SimpleApplicationEventMulticaster.multicastEvent(SimpleApplicationEventMulticaster.java:76) >> >>> > at >> >>> > >> >>> >> org.springframework.context.support.AbstractApplicationContext.publishEvent(AbstractApplicationContext.java:274) >> >>> > at >> >>> > >> >>> >> org.springframework.context.support.AbstractApplicationContext.finishRefresh(AbstractApplicationContext.java:736) >> >>> > at >> >>> > >> >>> >> org.springframework.osgi.context.support.AbstractOsgiBundleApplicationContext.finishRefresh(AbstractOsgiBundleApplicationContext.java:235) >> >>> > at >> >>> > >> >>> >> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext$4.run(AbstractDelegatedExecutionApplicationContext.java:358) >> >>> > at >> >>> > >> >>> >> org.springframework.osgi.util.internal.PrivilegedUtils.executeWithCustomTCCL(PrivilegedUtils.java:85) >> >>> > at >> >>> > >> >>> >> org.springframework.osgi.context.support.AbstractDelegatedExecutionApplicationContext.completeRefresh(AbstractDelegatedExecutionApplicationContext.java:320) >> >>> > at >> >>> > >> >>> >> org.springframework.osgi.extender.internal.dependencies.startup.DependencyWaiterApplicationContextExecutor$CompleteRefreshTask.run(DependencyWaiterApplicationContextExecutor.java:136) >> >>> > at java.lang.Thread.run(Thread.java:619) >> >>> > Caused by: java.lang.IllegalArgumentException: policy must be >> specified >> >>> on: >> >>> > Transacted[ref: null] >> >>> > at >> org.apache.camel.util.ObjectHelper.notNull(ObjectHelper.java:258) >> >>> > at >> >>> > >> >>> >> org.apache.camel.model.TransactedDefinition.createProcessor(TransactedDefinition.java:129) >> >>> > at >> >>> > >> >>> >> org.apache.camel.model.ProcessorDefinition.makeProcessor(ProcessorDefinition.java:226) >> >>> > at >> >>> > >> >>> >> org.apache.camel.model.ProcessorDefinition.addRoutes(ProcessorDefinition.java:111) >> >>> > at >> >>> > >> >>> >> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:294) >> >>> > at >> >>> > >> >>> >> org.apache.camel.model.RouteDefinition.addRoutes(RouteDefinition.java:120) >> >>> > at >> >>> > >> >>> >> org.apache.camel.impl.DefaultCamelContext.startRoute(DefaultCamelContext.java:552) >> >>> > at >> >>> > >> >>> >> org.apache.camel.impl.DefaultCamelContext.startRouteDefinitions(DefaultCamelContext.java:969) >> >>> > at >> >>> > >> >>> >> org.apache.camel.impl.DefaultCamelContext.doStart(DefaultCamelContext.java:946) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.SpringCamelContext.maybeDoStart(SpringCamelContext.java:165) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.SpringCamelContext.doStart(SpringCamelContext.java:160) >> >>> > at >> org.apache.camel.impl.ServiceSupport.start(ServiceSupport.java:52) >> >>> > at >> >>> > >> >>> >> org.apache.camel.impl.DefaultCamelContext.start(DefaultCamelContext.java:863) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.SpringCamelContext.maybeStart(SpringCamelContext.java:99) >> >>> > at >> >>> > >> >>> >> org.apache.camel.spring.SpringCamelContext.onApplicationEvent(SpringCamelContext.java:119) >> >>> > Charles Moulliard >> >>> > Senior Enterprise Architect >> >>> > Apache Camel Committer >> >>> > >> >>> > ***************************** >> >>> > blog : http://cmoulliard.blogspot.com >> >>> > >> >>> >> >>> >> >>> >> >>> -- >> >>> Claus Ibsen >> >>> Apache Camel Committer >> >>> >> >>> Open Source Integration: http://fusesource.com >> >>> Blog: http://davsclaus.blogspot.com/ >> >>> Twitter: http://twitter.com/davsclaus >> >>> >> >> >> >> >> > >> >> >> >> -- >> Claus Ibsen >> Apache Camel Committer >> >> Open Source Integration: http://fusesource.com >> Blog: http://davsclaus.blogspot.com/ >> Twitter: http://twitter.com/davsclaus >> > -- Claus Ibsen Apache Camel Committer Open Source Integration: http://fusesource.com Blog: http://davsclaus.blogspot.com/ Twitter: http://twitter.com/davsclaus
