reta commented on code in PR #940:
URL: https://github.com/apache/cxf/pull/940#discussion_r855677308


##########
rt/transports/jms/src/test/java/org/apache/cxf/transport/jms/util/MessageListenerTest.java:
##########
@@ -174,33 +183,21 @@ private void testTransactionalBehaviour(Connection 
connection, Queue dest) throw
     }
 
     private static Connection createConnection(String name) throws 
JMSException {
-        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://" + 
name
-                                                                     + 
"?broker.persistent=false");
-        cf.setRedeliveryPolicy(redeliveryPolicy());
+        ActiveMQConnectionFactory cf = new ActiveMQConnectionFactory("vm://" + 
name);
         Connection connection = cf.createConnection();
         connection.start();
         return connection;
     }
 
     private static Connection createXAConnection(String name, 
TransactionManager tm) throws JMSException {
-        ActiveMQXAConnectionFactory cf = new 
ActiveMQXAConnectionFactory("vm://" + name
-                                                                         + 
"?broker.persistent=false&jms.xaAckMode=1");
-        cf.setRedeliveryPolicy(redeliveryPolicy());
-        XaPooledConnectionFactory cfp = new XaPooledConnectionFactory(cf);
-        cfp.setTransactionManager(tm);
-        cfp.setConnectionFactory(cf);
-        Connection connection = cfp.createConnection();
+        ActiveMQXAConnectionFactory cf = new 
ActiveMQXAConnectionFactory("vm://" + name);
+        ConnectionFactory cf1 = new ConnectionFactoryProxy(cf, new 
TransactionHelperImpl(tm));

Review Comment:
   @ehsavoie I found a simpler way to integrate with JTA using 
`ConnectionFactoryProxy` and `TransactionHelperImpl`, the tests are passing 
right now (except `testConnectionProblemXA`, it has different cause).
   
   ```
   [ERROR] Failures:
   [ERROR]   
JMSDestinationTest.testDoNotCreateSecurityContext:545->testSecurityContext:558->AbstractJMSTester.waitForReceiveDestMessage:278
 Can't receive the Destination message in 10 seconds
   [ERROR]   
JMSDestinationTest.testProperty:424->verifyRequestResponseHeaders:303 The 
message encoding should be equal expected:<U[TF-8]> but was:<U[S-ASCII]>
   [ERROR]   JMSDestinationTest.testRoundTripDestination:316 SecurityContext 
should be set in message received by JMSDestination
   [ERROR]   JMSDestinationTest.testSecurityContext:538 SecurityContext should 
be set in message received by JMSDestination
   [ERROR]   JMSDestinationTest.testTemporaryQueueDeletionUponReset:511
   Expected: <1>
        but: was <0>
   [ERROR]   MessageListenerTest.testConnectionProblemXA:104
   Expected: a string containing "Wrapped exception."
        but: was "Connection is closed"
   [INFO]
   [ERROR] Tests run: 65, Failures: 6, Errors: 0, Skipped: 1
   [INFO]
   ```



-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: dev-unsubscr...@cxf.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to