Author: ataylor
Date: 2010-07-21 09:48:50 -0400 (Wed, 21 Jul 2010)
New Revision: 9448
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/xa/BasicXaRecoveryTest.java
Log:
fix xa test
Modified:
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/xa/BasicXaRecoveryTest.java
===================================================================
---
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/xa/BasicXaRecoveryTest.java 2010-07-21
13:39:48 UTC (rev 9447)
+++
branches/2_2_0_HA_Improvements/tests/src/org/hornetq/tests/integration/xa/BasicXaRecoveryTest.java 2010-07-21
13:48:50 UTC (rev 9448)
@@ -59,6 +59,8 @@
private final SimpleString atestq = new SimpleString("atestq");
+ private ServerLocator locator;
+
@Override
protected void setUp() throws Exception
{
@@ -1261,8 +1263,8 @@
private void createClients(final boolean createQueue, final boolean commitACKs) throws
Exception
{
- ServerLocator locator = createInVMNonHALocator();
- ClientSessionFactory sf = locator.createSessionFactory();
+ locator = createInVMNonHALocator();
+ sessionFactory = locator.createSessionFactory();
clientSession = sessionFactory.createSession(true, false, commitACKs);
if (createQueue)
{