mirror of https://github.com/apache/activemq.git
git-svn-id: https://svn.apache.org/repos/asf/activemq/trunk@1453964 13f79535-47bb-0310-9956-ffa450edef68
This commit is contained in:
parent
5abd154e19
commit
2d46399ff3
|
@ -40,11 +40,18 @@ public class JDBCXACommitExceptionTest extends JDBCCommitExceptionTest {
|
|||
|
||||
private long txGenerator = System.currentTimeMillis();
|
||||
|
||||
protected ActiveMQXAConnectionFactory factory = new ActiveMQXAConnectionFactory(
|
||||
"tcp://localhost:61616?jms.prefetchPolicy.all=0&jms.redeliveryPolicy.maximumRedeliveries="+messagesExpected);
|
||||
protected ActiveMQXAConnectionFactory factory;
|
||||
|
||||
boolean onePhase = true;
|
||||
|
||||
@Override
|
||||
public void setUp() throws Exception {
|
||||
super.setUp();
|
||||
|
||||
factory = new ActiveMQXAConnectionFactory(
|
||||
connectionUri + "?jms.prefetchPolicy.all=0&jms.redeliveryPolicy.maximumRedeliveries="+messagesExpected);
|
||||
}
|
||||
|
||||
public void testTwoPhaseSqlException() throws Exception {
|
||||
onePhase = false;
|
||||
doTestSqlException();
|
||||
|
|
Loading…
Reference in New Issue