Return-Path: 
 <users-return-20169-apmail-camel-users-archive=camel.apache.org@camel.apache.org>
X-Original-To: apmail-camel-users-archive@www.apache.org
Delivered-To: apmail-camel-users-archive@www.apache.org
Received: from mail.apache.org (hermes.apache.org [140.211.11.3])
	by minotaur.apache.org (Postfix) with SMTP id 148865C15
	for <apmail-camel-users-archive@www.apache.org>;
 Tue, 10 May 2011 06:40:52 +0000 (UTC)
Received: (qmail 15499 invoked by uid 500); 10 May 2011 06:40:51 -0000
Delivered-To: apmail-camel-users-archive@camel.apache.org
Received: (qmail 15472 invoked by uid 500); 10 May 2011 06:40:51 -0000
Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
List-Help: <mailto:users-help@camel.apache.org>
List-Unsubscribe: <mailto:users-unsubscribe@camel.apache.org>
List-Post: <mailto:users@camel.apache.org>
List-Id: <users.camel.apache.org>
Reply-To: users@camel.apache.org
Delivered-To: mailing list users@camel.apache.org
Received: (qmail 15464 invoked by uid 99); 10 May 2011 06:40:51 -0000
Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 May 2011 06:40:51 +0000
X-ASF-Spam-Status: No, hits=-0.7 required=5.0
	tests=FREEMAIL_FROM,RCVD_IN_DNSWL_LOW,RFC_ABUSE_POST,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL
X-Spam-Check-By: apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.212.169 as permitted sender)
Received: from [209.85.212.169] (HELO mail-px0-f169.google.com)
 (209.85.212.169)
    by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 10 May 2011 06:40:46 +0000
Received: by pxi9 with SMTP id 9so4666281pxi.14
        for <users@camel.apache.org>; Mon, 09 May 2011 23:40:26 -0700 (PDT)
DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed;
        d=gmail.com; s=gamma;
        h=domainkey-signature:mime-version:in-reply-to:references:from:date
         :message-id:subject:to:content-type:content-transfer-encoding;
        bh=Jk8QO5/AUN/vB15Dh99RbAQgKt0sxLTijB1TgaeQvTo=;
        b=ucxWdBjuKxPoiwy23WbsS/b7VTktcN82oOOzb/C8OOjRO+dzjuNEPXGAsArMpKluOR
         4mxqq5QVVTT6NQkQ4GZ4htKo7tf2mm+ENIleWu+wKIjaWbLuoS9Hc878O3Ae8nT49iZh
         sXdI1bMA5b/trlWkOnx8UCrT7oCVKF5M2K10I=
DomainKey-Signature: a=rsa-sha1; c=nofws;
        d=gmail.com; s=gamma;
        h=mime-version:in-reply-to:references:from:date:message-id:subject:to
         :content-type:content-transfer-encoding;
        b=bGCxpfgHs0Fp6BLfiqjlSjHxUt1HwizhppQ+lclrR0JzCfqBLBEK/f64raavY1lAIN
         fjE0bFWNfxbBRlwx+IRO/jG4OADPW59G4BgRT9IJVRLLvYM/Ny39hLlM0U8IXmR/cOXE
         UtYIVt/Ktymzj6Xfd5CbAe55pcwXyPUTwMJW4=
Received: by 10.68.47.198 with SMTP id f6mr7565881pbn.511.1305009626084; Mon,
 09 May 2011 23:40:26 -0700 (PDT)
MIME-Version: 1.0
Received: by 10.68.46.67 with HTTP; Mon, 9 May 2011 23:40:06 -0700 (PDT)
In-Reply-To: <BANLkTi=70DZEx2+hnA_qH2nm9shkRRwDOg@mail.gmail.com>
References: <BANLkTikPO380Uz9743kSWanPP4a57j9_tg@mail.gmail.com>
 <1304942448167-4381695.post@n5.nabble.com>
 <BANLkTi=pt=_BvRNsb9WKLJRmA7+jNrtn0Q@mail.gmail.com>
 <1304973829545-4382912.post@n5.nabble.com>
 <BANLkTi=70DZEx2+hnA_qH2nm9shkRRwDOg@mail.gmail.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Tue, 10 May 2011 08:40:06 +0200
Message-ID: <BANLkTim3yBKmFFtqa25mFPc1MMRZ54t+OQ@mail.gmail.com>
Subject: Re: Problem with JMS transaction
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

Remove this
        <property name=3D"acknowledgementModeName"  value=3D"CLIENT_ACKNOWL=
EDGE"/>

As when you use transacted=3Dtrue, it has to use TRANSACTED_ACKNOWLEDGE.
So do not override/change this setting.

2011/5/10 C=E9line Bugaud <c.bugaud@gmail.com>:
> Hi Ashwin,
>
> I didn't sent my entire spring configuration, but my ActiveMQComponent
> was already linked to the transactionManager :
>
> ----------------------------------------------------
> =A0 =A0 =A0 =A0<bean id=3D"activemqPersistent"
> class=3D"org.apache.activemq.camel.component.ActiveMQComponent"
> =A0 =A0 =A0 =A0lazy-init=3D"true">
> =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"connectionFactory"
> ref=3D"amqPoolConnectionFactory"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"transactionManager" =A0 =
=A0 =A0 ref=3D"amqTransactionManager"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"transacted" =A0 =A0 =A0 =
=A0 =A0 =A0 =A0 value=3D"true"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"brokerURL" =A0 =A0 =A0 =
=A0 =A0 =A0 =A0 =A0value=3D"${bo.activemq.brokerurl}" />
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"acknowledgementModeName"=
 =A0value=3D"CLIENT_ACKNOWLEDGE"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"maxConcurrentConsumers" =
=A0 value=3D"10" />
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"receiveTimeout" =A0 =A0 =
=A0 =A0 =A0 value=3D"3000"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"maxMessagesPerTask" =A0 =
=A0 =A0 value=3D"1"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"deliveryPersistent" =A0 =
=A0 =A0 value=3D"true"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"usePooledConnection" =A0=
 =A0 =A0value=3D"true"/>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0<property name=3D"testConnectionOnStartup"=
 =A0value=3D"true"/>
> =A0 =A0 =A0 =A0</bean>
> ----------------------------------------------------
>
> However, I tried using two different activeMQComponent, and that
> seemed to solve my problem : I no longer loose messages. The
> transaction does not seem to work well either : I now have duplicate
> messages.
>
> Regards,
>
> --
> C=E9line
>
> On Mon, May 9, 2011 at 10:43 PM, Ashwin Karpe <akarpe@fusesource.com> wro=
te:
>> Hi,
>>
>> Sorry about the confusion... You do not need the second connection facto=
ry
>> "activemq2". This is an error on my part.
>>
>> The key difference in your setup vs mine is that there is a
>> "transactionManager" property set in my ActiveMQ component and the
>> "transacted" property is set to true . This wires in the transactional
>> capability to the ActiveMQ component.
>>
>> Please see the corrected XML below.
>>
>> Cheers,
>>
>> Ashwin...
>>
>>
>>
>> =3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=
=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D=3D
>> ----------------------------------------------------
>> <beans xmlns=3D"http://www.springframework.org/schema/beans"
>> =A0 =A0 =A0 xmlns:xsi=3D"http://www.w3.org/2001/XMLSchema-instance"
>> =A0 =A0 =A0 xmlns:camel=3D"http://camel.apache.org/schema/spring"
>> =A0 =A0 =A0 xsi:schemaLocation=3D"
>> =A0 =A0 =A0 =A0 http://www.springframework.org/schema/beans
>> http://www.springframework.org/schema/beans/spring-beans.xsd
>> =A0 =A0 =A0 =A0 http://camel.apache.org/schema/spring
>> http://camel.apache.org/schema/spring/camel-spring.xsd">
>>
>> =A0 =A0 <camelContext>
>> =A0 =A0 =A0 =A0 =A0 =A0<route>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <from ref=3D"activemq:queue:foo" />
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <transacted ref=3D"required"/>
>> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 <to ref=3D"activemq:topic:bar" />
>> =A0 =A0 =A0 =A0 =A0 =A0</route>
>> =A0 =A0 </camelContext>
>>
>> =A0 =A0<bean id=3D"jmsConnectionFactory"
>> class=3D"org.apache.activemq.ActiveMQConnectionFactory">
>> =A0 =A0 =A0 =A0<property name=3D"brokerURL"
>> value=3D"vm://localhost?broker.persistent=3Dfalse&amp;broker.useJmx=3Dfa=
lse"/>
>> =A0 =A0</bean>
>>
>> =A0 =A0<bean id=3D"jmsTransactionManager"
>> class=3D"org.springframework.jms.connection.JmsTransactionManager">
>> =A0 =A0 =A0 =A0<property name=3D"connectionFactory" ref=3D"jmsConnection=
Factory"/>
>> =A0 =A0</bean>
>>
>> =A0 =A0<bean id=3D"activemq"
>> class=3D"org.apache.activemq.camel.component.ActiveMQComponent">
>> =A0 =A0 =A0 =A0<property name=3D"connectionFactory" ref=3D"jmsConnection=
Factory"/>
>> =A0 =A0 =A0 =A0<property name=3D"transacted" value=3D"true"/>
>> =A0 =A0 =A0 =A0<property name=3D"transactionManager" ref=3D"jmsTransacti=
onManager"/>
>> =A0 =A0</bean>
>>
>> =A0 <bean id=3D"required"
>> class=3D"org.apache.camel.spring.spi.SpringTransactionPolicy">
>> =A0 =A0 =A0 =A0 <property name=3D"transactionManager" ref=3D"amqTransact=
ionManager" />
>> =A0 =A0 =A0 =A0 <property name=3D"propagationBehaviorName"
>> value=3D"PROPAGATION_MANDATORY" />
>> =A0 </bean>
>>
>> </beans>
>>
>



--=20
Claus Ibsen
-----------------
FuseSource
Email: cibsen@fusesource.com
Web: http://fusesource.com
CamelOne 2011: http://fusesource.com/camelone2011/
Twitter: davsclaus
Blog: http://davsclaus.blogspot.com/
Author of Camel in Action: http://www.manning.com/ibsen/