Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: domain of chirino@gmail.com designates
 64.233.162.199 as permitted sender)
DomainKey-Signature: a=rsa-sha1; q=dns; c=nofws;
        s=beta; d=gmail.com;
        h=received:message-id:date:from:sender:to:subject:in-reply-to:mime-version:content-type:content-transfer-encoding:content-disposition:references;
        b=ThTB0YsdmXeGJBe2RCiLSNL19tEvE/EcktOh1qSgxMZh8aG0L9FAZyGz62JX/UJzlaYHwAuESVX/lAXKCWd3eQ5JgXD1JbjFh42fClZxmpBPX4NxEsXPeN7x163Wx48zqby5P0bnbkZx9M3wwR4nw0EB/nieOAI6tWBotcoKNJk=
Message-ID: <af2843cd0603311326x6538d71erfaca9b107e12cbfc@mail.gmail.com>
Date: Fri, 31 Mar 2006 16:26:42 -0500
From: "Hiram Chirino" <hiram@hiramchirino.com>
Sender: chirino@gmail.com
To: activemq-users@geronimo.apache.org
Subject: Re: ActiveMQ and JTA
In-Reply-To: <3E7FE7F1841E3441A566885FEDDCDECE43BD24@SPR3V2.office.local>
MIME-Version: 1.0
Content-Type: text/plain; charset=ISO-8859-1
Content-Transfer-Encoding: quoted-printable
Content-Disposition: inline
References: <3E7FE7F1841E3441A566885FEDDCDECE43BD24@SPR3V2.office.local>

Hi Meeraj,

To have activemq connections be controlled by the J2EE container, you
must use connections that have been created using the ActiveMQ
resource adapter.

See:
http://activemq.com/Resource+Adapter

Regards,
Hiram

On 3/31/06, Meeraj Kunnumpurath <M.Kunnumpurath@voca.com> wrote:
> Hi,
>
> I am using ActiveMQ 4.0 M4 standalone with the message consumers and
> producers running from a separate Weblogic instance. I have got the
> following code to send a message using JTA transaction demarcation,
>
> Context ctx =3D null;
> Connection con =3D null;
> Session sess =3D null;
>
> try {
>         context =3D new InitialContext();
>         UserTransaction utx =3D
> (UserTransaction)ctx.lookup("javax.transaction.UserTransaction");
>         utx.begin();
>
>         ConnectionFactory cf =3D new
> ActiveMQConnectionFactory("tcp://localhost:61616");
>         Destination dst =3D new ActiveMQQueue("submission.queue");
>         Connection con =3D cf.createConnection();
>         Session sess =3D con.createSession(false,
> Session.AUTO_ACKNOWLEDGE);
>
>         MessageProducer prod =3D sess.createProducer(dst);
>         prod.send(sess.createTextMessage("Test"));
>
>         con.stop();
>         utx.rollback();
>
> } catch(Exception ex) {
>         throw new RuntimeException(ex);
> } finally {
>         closeResources(ctx, con, sess);
> }
>
> The message is still being published, despite the transaction being
> rolled back. Do I need to do anything else so that the ActiveMQ session
> get enlisted with the transaction manager.
>
> Any pointers would be highly appreciated.
>
> Kind Regards
>
> Meeraj
>
>
>
> *****************************************************
>
>     You can find us at www.voca.com
>
> *****************************************************
> This communication is confidential and intended for
> the exclusive use of the addressee only. You should
> not disclose its contents to any other person.
> If you are not the intended recipient please notify
> the sender named above immediately.
>
> Registered in England, No 1023742,
> Registered Office: Voca Limited
> Drake House, Three Rivers Court,
> Homestead Road, Rickmansworth,
> Hertfordshire, WD3 1FX
>
>
> This message has been checked for all email viruses by MessageLabs.
>


--
Regards,
Hiram