Distributed Transaction using ActiveMQ/JOTM/JDBC

[balpeck <ba...@gmail.com>]

Hi everyone,
I am trying to get a distributed transaction going with JOTM as a
transaction manager and ActiveMQ and JDBC as participants in the distributed
transaction. I'm very new to both JOTM and ActiveMQ. 

As I understand it now,
I need to create a TransactionManager, get an XAResource for ActiveMQ and my
DBMS(Postgresql), enlist them, get a USerTransaction and do a begin and an
end.. 
Is this roughly correct??

In am attempt of doing so.. I ran into a problem of the
connFac.createXAConnection() method not returning.It just hangs and returns
once I terminate the broker. Anything I may have missed?

import org.objectweb.jotm.Jotm;
import org.objectweb.transaction.jta.TMService;
import javax.transaction.*;
import javax.transaction.xa.*;
import org.apache.activemq.*;

public class TestXAJms
{
	static String user = ActiveMQConnection.DEFAULT_USER;
	static String password = ActiveMQConnection.DEFAULT_PASSWORD;
	static String url = ActiveMQConnection.DEFAULT_BROKER_URL;

	static public void main(String[]args)
	{
		try
		{
			/// Get the transaction Manager
			Jotm jotm = new Jotm(true, false);
			TransactionManager tm = jotm.getTransactionManager();
			Transaction tx = tm.getTransaction();

			/// Try to get to the XAResource for ActiveMQ
			ActiveMQXAConnectionFactory connFac = new
ActiveMQXAConnectionFactory(user,password,url);
			javax.jms.XAConnection xa_conn = connFac.createXAConnection();



		}
		catch(Exception e)
		{
			e.printStackTrace();
		}
	}
}

I appreciate any pointers on how to get a distributed transaction involving
ActiveMQ going. 

Thanks,
Balpeck


-- 
View this message in context: http://www.nabble.com/Distributed-Transaction-using-ActiveMQ-JOTM-JDBC-tf4786860s2354.html#a13694083
Sent from the ActiveMQ - User mailing list archive at Nabble.com.