[jboss-cvs] JBoss Messaging SVN: r2437 - trunk/tests/src/org/jboss/test/messaging/jms.

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

Author: ovidiu.feodorov at jboss.com
Date: 2007-02-26 01:47:01 -0500 (Mon, 26 Feb 2007)
New Revision: 2437

Modified:
   trunk/tests/src/org/jboss/test/messaging/jms/FailoverTest.java
Log:
Tim, please move this manual test somewhere else and rename it not to end in Test, because it screws up the automated test results

Modified: trunk/tests/src/org/jboss/test/messaging/jms/FailoverTest.java
===================================================================
--- trunk/tests/src/org/jboss/test/messaging/jms/FailoverTest.java	2007-02-26 06:01:36 UTC (rev 2436)
+++ trunk/tests/src/org/jboss/test/messaging/jms/FailoverTest.java	2007-02-26 06:47:01 UTC (rev 2437)
@@ -64,92 +64,92 @@
       
    }
    
-   public void testSendReceive() throws Exception
-   {            
-      Hashtable properties = new Hashtable();
-         
-      properties.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
-      
-      properties.put("java.naming.provider.url", "jnp://192.168.1.11:1199");
-      
-      properties.put("java.naming.factory.url", "org.jnp.interfaces");
-      
-      log.info("Creaing ic");
-      
-      InitialContext ic = new InitialContext(properties);
-      
-      log.info("************ REMOTE");
-      
-      Connection conn = null;
-      
-      try
-      {           
-         log.info("Created ic");
-         
-         Queue queue = (Queue)ic.lookup("/queue/testDistributedQueue");
-         
-         log.info("Looked up queue");
-         
-         ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
-         
-         log.info("Looked up cf");
-          
-         conn = cf.createConnection();
-         
-         Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-         
-         Session sessCons = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-         
-         MessageConsumer cons = sessCons.createConsumer(queue);
-         
-         MessageListener list = new MyListener();
-         
-         cons.setMessageListener(list);
-         
-         conn.start();
-         
-         MessageProducer prod = sessSend.createProducer(queue);
-        
-         prod.setDeliveryMode(DeliveryMode.PERSISTENT);
-         
-         int count = 0;
-         
-         while (true)
-         {
-            TextMessage tm = sessSend.createTextMessage("message " + count);
-            
-            prod.send(tm);
-            
-            log.info("sent " + count);
-            
-            count++;
-            
-            //Thread.sleep(250);
-         }
-         
-         
-      }
-      catch (Exception e)
-      {
-         log.error("Failed", e);
-         throw e;
-      }
-      finally
-      {      
-//         if (conn != null)
+//   public void testSendReceive() throws Exception
+//   {
+//      Hashtable properties = new Hashtable();
+//
+//      properties.put("java.naming.factory.initial", "org.jnp.interfaces.NamingContextFactory");
+//
+//      properties.put("java.naming.provider.url", "jnp://192.168.1.11:1199");
+//
+//      properties.put("java.naming.factory.url", "org.jnp.interfaces");
+//
+//      log.info("Creaing ic");
+//
+//      InitialContext ic = new InitialContext(properties);
+//
+//      log.info("************ REMOTE");
+//
+//      Connection conn = null;
+//
+//      try
+//      {
+//         log.info("Created ic");
+//
+//         Queue queue = (Queue)ic.lookup("/queue/testDistributedQueue");
+//
+//         log.info("Looked up queue");
+//
+//         ConnectionFactory cf = (ConnectionFactory)ic.lookup("/ConnectionFactory");
+//
+//         log.info("Looked up cf");
+//
+//         conn = cf.createConnection();
+//
+//         Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//
+//         Session sessCons = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//
+//         MessageConsumer cons = sessCons.createConsumer(queue);
+//
+//         MessageListener list = new MyListener();
+//
+//         cons.setMessageListener(list);
+//
+//         conn.start();
+//
+//         MessageProducer prod = sessSend.createProducer(queue);
+//
+//         prod.setDeliveryMode(DeliveryMode.PERSISTENT);
+//
+//         int count = 0;
+//
+//         while (true)
 //         {
-//            log.info("closing connetion");
-//            try
-//            {
-//               conn.close();
-//            }
-//            catch (Exception ignore)
-//            {               
-//            }
-//            log.info("closed connection");
+//            TextMessage tm = sessSend.createTextMessage("message " + count);
+//
+//            prod.send(tm);
+//
+//            log.info("sent " + count);
+//
+//            count++;
+//
+//            //Thread.sleep(250);
 //         }
-      }     
-   }
+//
+//
+//      }
+//      catch (Exception e)
+//      {
+//         log.error("Failed", e);
+//         throw e;
+//      }
+//      finally
+//      {
+////         if (conn != null)
+////         {
+////            log.info("closing connetion");
+////            try
+////            {
+////               conn.close();
+////            }
+////            catch (Exception ignore)
+////            {
+////            }
+////            log.info("closed connection");
+////         }
+//      }
+//   }
    
    class MyListener implements MessageListener
    {