Mailing-List: contact users-help@camel.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@camel.apache.org
Received-SPF: pass (athena.apache.org: domain of claus.ibsen@gmail.com
 designates 209.85.215.45 as permitted sender)
Received-SPF: pass (google.com: domain of claus.ibsen@gmail.com designates
 10.152.102.173 as permitted sender) client-ip=10.152.102.173;
MIME-Version: 1.0
In-Reply-To: <1330734718974-5532697.post@n5.nabble.com>
References: <1330734718974-5532697.post@n5.nabble.com>
From: Claus Ibsen <claus.ibsen@gmail.com>
Date: Sat, 3 Mar 2012 10:27:58 +0100
Message-ID: 
 <CAGB5yN=amZkYrjh8XQTuLpnj0DnYvudLiy857ZtC6ZTEqw_tww@mail.gmail.com>
Subject: Re: help with websphere MQ with XA transaction. Sample code below.
To: users@camel.apache.org
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable

Hi

If you need XA then you need to use a XA transaction manager, as well
XA capable resources (in your case IBM WebSphereMQ) for the JMS broker
and then a XA JDBC driver for the JDBC.

So when you get the JDBC connection you need to get it in a way that
the XA transaction manager can orchestrate it.
I doubt by calling the code you do, works in that way. You may need to
check the documentation of your JDBC driver to learn how to do that.

Also if you got Camel in Action book, we cover all about transactions
and XA in chapter 9.
And have examples how to do XA with JMS and JDBC.


On Sat, Mar 3, 2012 at 1:31 AM, dmhatre <darpan27484@gmail.com> wrote:
> Hi Folks,
> =A0 I am new to Apache camel. And got the JMS websphere MQ with camel.
> But I am struggling with XA transaction. Can somebody help me and give so=
me
> leads to
> implement XA transaction. Below is the code sample which is working(but
> without XA transaction)
> The option transacted=3Dtrue uses JMSTransactionManager which kind off
> rollbacks the JMS transaction
> if database transaction fails. But want some more control by doing commit=
s
> and rollbacks manually.
> Thanks in advance.
>
>
> CamelContext context =3D new DefaultCamelContext();
>
> MQQueueConnectionFactory cf =3D new MQQueueConnectionFactory();
> =A0cf.setHostName("192.111.111.11");
> =A0cf.setPort(1414);
> =A0cf.setQueueManager("QM_user");
> =A0cf.setChannel("S_user");
> =A0cf.setTransportType(1);
> JmsConfiguration jc =3D new JmsConfiguration(cf);
> JmsComponent ibmmq =3D new JmsComponent(jc);
> =A0context.addComponent("test-jms", ibmmq);
>
> =A0context.addRoutes(new RouteBuilder() {
>
> =A0 =A0 =A0 =A0public void configure() {
>
> =A0 =A0 =A0 =A0from("test-jms:queue:Q1?transacted=3Dtrue").process(new Pr=
ocessor(){
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0public void process(Exchange arg0) throws =
Exception {
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 Object obj =3D arg0.getIn().getBo=
dy();
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 String sql =3D "insert into kk_te=
sttab(x,y) values(?,?)";
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 Connection conn =3D OceanviewData=
Source.getConnection();
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 PreparedStatement stmt =3D null;
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0try {
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0stmt =3D c=
onn.prepareStatement(sql);
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0stmt.setIn=
t(1, Integer.parseInt(obj.toString()));
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0stmt.setIn=
t(2, Integer.parseInt(obj.toString()));
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0stmt.execu=
te();
>
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}catch(Exc=
eption e){
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0throw e;
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}finally {
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =
=A0 =A0conn.close();
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0});
> =A0 =A0 =A0 =A0 =A0 =A0 =A0 =A0}
> =A0 =A0 =A0 =A0});
>
> =A0 context.start();
> =A0 Thread.sleep(1000);
> =A0 context.stop();
>
> --
> View this message in context: http://camel.465427.n5.nabble.com/help-with=
-websphere-MQ-with-XA-transaction-Sample-code-below-tp5532697p5532697.html
> Sent from the Camel - Users mailing list archive at Nabble.com.


--=20
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/