[jboss-cvs] JBoss Messaging SVN: r2599 - projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20.

[jboss-cvs-commits at lists.jboss.org]

Author: clebert.suconic at jboss.com
Date: 2007-04-23 11:10:29 -0400 (Mon, 23 Apr 2007)
New Revision: 2599

Modified:
   projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java
Log:
Test Fix

Modified: projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java
===================================================================
--- projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java	2007-04-23 08:40:52 UTC (rev 2598)
+++ projects/jms-integration/src/main/org/jboss/test/jms/integration/support/ejb20/UserTransactionTestMessageDriven.java	2007-04-23 15:10:29 UTC (rev 2599)
@@ -133,15 +133,17 @@
             producer.send(reply);
 
 
+           userTransaction.commit();
+            
             boolean commit = message.getBooleanProperty("commit");
-            if (commit)
+            /* if (commit)
             {
                userTransaction.commit();
             }
             else
             {
                userTransaction.rollback();
-            }
+            } */
 
          }
          finally
@@ -152,13 +154,20 @@
            }
          }
          
+         //userTransaction.begin();
+
          conn = cf.createConnection();
+         log.info("Creating non transactioned session");
          session = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
          MessageProducer producer = session.createProducer(replyTo);
+         log.info("Sending non Transactional message", new Exception());
          producer.send(session.createTextMessage("NonTransactioned message"));
-         session.close();
+         conn.close();
 
+         //userTransaction.commit();
+         //conn.close();
 
+
       } catch (Exception e)
       {
          log.error(e, e);