[Jboss-cvs] JBoss Messaging SVN: r1238 - branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms

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

Author: ovidiu.feodorov at jboss.com
Date: 2006-08-30 14:38:21 -0400 (Wed, 30 Aug 2006)
New Revision: 1238

Modified:
   branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/CTSMiscellaneousTest.java
Log:
the test is irrelevant, now that TCK fully passes. http://jira.jboss.org/jira/browse/JBMESSAGING-485

Modified: branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/CTSMiscellaneousTest.java
===================================================================
--- branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/CTSMiscellaneousTest.java	2006-08-30 18:36:36 UTC (rev 1237)
+++ branches/Branch_1_0/tests/src/org/jboss/test/messaging/jms/CTSMiscellaneousTest.java	2006-08-30 18:38:21 UTC (rev 1238)
@@ -209,99 +209,6 @@
       }
    }
 
-   // Temporarily commented out. See http://jira.jboss.org/jira/browse/JBMESSAGING-485
-
-//   public void testContestedQueueOnRollback() throws Exception
-//   {
-//      ConnectionFactory cf = (JBossConnectionFactory)ic.lookup("/ConnectionFactory");
-//      Queue queue = (Queue)ic.lookup("/queue/Queue");
-//
-//      Connection c =  cf.createConnection();
-//      try
-//      {
-//         Session s = c.createSession(false, Session.AUTO_ACKNOWLEDGE);
-//         TextMessage tm = s.createTextMessage("blah");
-//         s.createProducer(queue).send(tm);
-//      }
-//      finally
-//      {
-//         c.close();
-//      }
-//
-//      // message is in the queue
-//      log.debug("message is in the queue");
-//
-//      c = cf.createConnection();
-//      c.start();
-//
-//      try
-//      {
-//         Session s = c.createSession(true, Session.SESSION_TRANSACTED);
-//         MessageConsumer cons = s.createConsumer(queue);
-//
-//         Session s2 = c.createSession(true, Session.SESSION_TRANSACTED);
-//         final MessageConsumer cons2 = s2.createConsumer(queue);
-//
-//         Session sessionToRollback = s;
-//         MessageConsumer cc = cons2;
-//         TextMessage rm = (TextMessage)cons.receiveNoWait();
-//
-//         if (rm == null)
-//         {
-//            sessionToRollback = s2;
-//            cc = cons;
-//            rm = (TextMessage)cons.receiveNoWait();
-//         }
-//
-//         assertEquals("blah", rm.getText());
-//
-//         final Slot slot = new Slot();
-//         final MessageConsumer contestingConsumer = cc;
-//
-//         new Thread(new Runnable()
-//         {
-//            public void run()
-//            {
-//               try
-//               {
-//                  log.debug("contester blocking to receive");
-//                  Message m = contestingConsumer.receive(8000);
-//                  log.debug("contester received " + m);
-//
-//                  if (m != null)
-//                  {
-//                     // if I receive a message, unlock the slot
-//                     slot.put(m);
-//                  }
-//               }
-//               catch(Exception e)
-//               {
-//                  log.error("contested receive failed", e);
-//               }
-//            }
-//         }, "Contester Thread").start();
-//
-//         // wait for the contested thread to start receiving
-//         Thread.sleep(2000);
-//
-//         // send the message back to the queue
-//         log.debug("rolling back");
-//         sessionToRollback.rollback();
-//         log.debug("rolled back");
-//
-//         // wait for the contester to receive
-//         TextMessage rm2 = (TextMessage)slot.poll(5000);
-//
-//         assertEquals("blah", rm2.getText());
-//      }
-//      finally
-//      {
-//         log.debug("closing connection");
-//         c.close();
-//      }
-//   }
-
-
    // Package protected ---------------------------------------------
 
    // Protected -----------------------------------------------------