JTA and JMS Hornetq Transactions

[murthy516]

Hi,

   I've a JTA Transaction which pushes the message to one of the remote queue (sitting in some other server) using Remote connection factory,and the same transaction includes the updation of table in database.

Problem is if any updation of jta transaction fails,I'm unable to rollback the message which pushed earlier.Message pushing was done by establishing Remote Connection Factory and Session as non-transacted session.

  Hashtable<String, String> env = new Hashtable<String, String>();

      env.put(Context.INITIAL_CONTEXT_FACTORY, "org.jboss.naming.remote.client.InitialContextFactory");

      env.put(Context.URL_PKG_PREFIXES, "org.jnp.interfaces:org.jboss.naming");

      env.put(Context.PROVIDER_URL, "remote://122.162.2.207:4447");

  env.put(Context.SECURITY_PRINCIPAL, userName);

  env.put(Context.SECURITY_CREDENTIALS, password);

  initialContext = new InitialContext(env);

  connectionFactory = (ConnectionFactory) initialContext.lookup("jms/RemoteConnectionFactory");

  Queue queue = (Queue) initialContext.lookup(queueName);

  connection = connectionFactory.createConnection(userName, password);

  session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);

  TextMessage message = session.createTextMessage(textMessage);

  MessageProducer sender = session.createProducer(queue);

  sender.send(message);

  connection.start();

  connection.close();

How can i commit both these at a time.Does the above code fits Ok?Please help me out JBOSS Team.

Regards

Krisv

[murthy516]

Anyone Der??

[jmesnil]

In which environment are you running? Servlet container, EJB container, a normal Java application?

You should read http://docs.oracle.com/cd/E19798-01/821-1841/bncgl/index.html that explains how to use distributed transactions with JMS?

[murthy516]

Hi Jeff,

   Thanks for the response..Many thanks.I'm facing this one in EJB Container.@TransactionManagement is by Container and @TransactionType is Required.I'm able to combine this JMS and JTA Transactions commit together if the Queue is LocalQueue and using JmsXA ConnectionFactory.But if the queue is sitting on remote server,i'm using jms/RemoteConnectionFactory and the message is not being rollbacked if any ejb persistence got failed in that JTA Transaction.Pls help me

Regards

Krisv