Я провожу некоторые тесты с транзакциями Hazelcast XA, и у меня возникают проблемы при использовании Bitronix в качестве менеджера транзакций.
Я следил за официальной документацией Hazelcast:
http://docs.hazelcast.org/docs/3.5/manual/html/xatransactions.html
Версии библиотек:
Hazelcast: 3.5.4
Bitronix Transaction Manager: 2.1.4
Java: 1.7
Код:
Метод тестирования:
@Test
public void hazelcastBitronixXATransactionTest() throws Exception{
try{
doHazelcastXATransactionTest(createInstance("myCluster"));
}catch(Exception e){
Assert.fail();
System.out.println("Other Exception:" + e.getMessage());
}
}
Метод создания экземпляра Hazelcast:
private HazelcastInstance createInstance(String clusterName){
System.setProperty("hazelcast.logging.type", "slf4j");
Config config = new Config();
config.getGroupConfig().setName(clusterName);
config.getNetworkConfig().getJoin().getMulticastConfig().setEnabled(true);
TcpIpConfig tcpIpConfig = config.getNetworkConfig().getJoin().getTcpIpConfig();
tcpIpConfig.setEnabled(false);
return Hazelcast.newHazelcastInstance(config);
}
Метод выполнения:
private void doHazelcastXATransactionTest(HazelcastInstance hazelcastInstance) throws Exception{
BitronixTransactionManager btm = TransactionManagerServices.getTransactionManager();
btm.setTransactionTimeout(60);
btm.begin();
HazelcastXAResource xaResource = hazelcastInstance.getXAResource();
Transaction transaction = btm.getTransaction();
transaction.enlistResource(xaResource);
try {
TransactionContext context = xaResource.getTransactionContext();
TransactionalMap map = context.getMap("m");
map.put("key", "value");
transaction.delistResource(xaResource, XAResource.TMSUCCESS);
btm.commit();
} catch (Exception e) {
System.out.println("Exception do rollback:" + e.getMessage());
btm.rollback();
}
}
Я получаю BitronixSystemException
, выдаваемый при попытке заручиться ресурсом XA transaction.enlistResource(xaResource)
.
Полная трассировка стека:
bitronix.tm.internal.BitronixSystemException: unknown XAResource HazelcastXaResource {myCluster}, it does not belong to a registered resource
Кто-то сталкивался с этой проблемой? Любые подсказки по этому поводу?