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

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

Author: timfox
Date: 2008-05-27 10:53:15 -0400 (Tue, 27 May 2008)
New Revision: 4308

Modified:
   trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java
Log:
Commented out tests until beta


Modified: trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java
===================================================================
--- trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java	2008-05-27 14:17:45 UTC (rev 4307)
+++ trunk/tests/jms-tests/src/org/jboss/test/messaging/jms/MessageConsumerTest.java	2008-05-27 14:53:15 UTC (rev 4308)
@@ -3742,100 +3742,100 @@
       }
    }
 
+// http://jira.jboss.org/jira/browse/JBMESSAGING-1294 - commented out until 2.0 beta
+//   public void testExceptionMessageListener1() throws Exception
+//   {
+//   	Connection conn = null;
+//      
+//      try
+//      {	      
+//	      conn = cf.createConnection();
+//
+//	      conn.start();
+//	
+//	      Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//	
+//	      Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//	
+//	      MessageConsumer cons = sess.createConsumer(queue1);
+//	
+//	      ExceptionRedelMessageListenerImpl listener = new ExceptionRedelMessageListenerImpl(sess);
+//	
+//	      cons.setMessageListener(listener);
+//	
+//	      MessageProducer prod = sessSend.createProducer(queue1);
+//	      TextMessage m1 = sess.createTextMessage("a");
+//	      TextMessage m2 = sess.createTextMessage("b");
+//	      TextMessage m3 = sess.createTextMessage("c");
+//	
+//	      prod.send(m1);
+//	      prod.send(m2);
+//	      prod.send(m3);
+//	
+//	      listener.waitForMessages();
+//	
+//	      assertFalse(listener.message, listener.failed);
+//	
+//	      conn.close();
+//	      
+//	      conn = null;
+//	   }
+//	   finally
+//	   {
+//	   	if (conn != null)
+//	   	{
+//	   		conn.close();
+//	   	}
+//	   }
+//   }
+//
+//   public void testExceptionMessageListener2() throws Exception
+//   {
+//   	Connection conn = null;
+//      
+//      try
+//      {	      
+//	      conn = cf.createConnection();
+//
+//	      conn.start();
+//	
+//	      Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
+//	
+//	      Session sess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
+//	
+//	      MessageConsumer cons = sess.createConsumer(queue1);
+//	
+//	      ExceptionRedelMessageListenerImpl listener = new ExceptionRedelMessageListenerImpl(sess);
+//	
+//	      cons.setMessageListener(listener);
+//	
+//	      MessageProducer prod = sessSend.createProducer(queue1);
+//	      TextMessage m1 = sess.createTextMessage("a");
+//	      TextMessage m2 = sess.createTextMessage("b");
+//	      TextMessage m3 = sess.createTextMessage("c");
+//	
+//	      prod.send(m1);
+//	      prod.send(m2);
+//	      prod.send(m3);
+//	
+//	      listener.waitForMessages();
+//	
+//	      assertFalse(listener.message, listener.failed);
+//	  	
+//	
+//	      conn.close();
+//	      
+//	      conn = null;
+//	   }
+//	   finally
+//	   {
+//	   	if (conn != null)
+//	   	{
+//	   		conn.close();
+//	   	}
+//	   }
+//   }
 
-   public void testExceptionMessageListener1() throws Exception
-   {
-   	Connection conn = null;
-      
-      try
-      {	      
-	      conn = cf.createConnection();
-
-	      conn.start();
-	
-	      Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-	
-	      Session sess = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-	
-	      MessageConsumer cons = sess.createConsumer(queue1);
-	
-	      ExceptionRedelMessageListenerImpl listener = new ExceptionRedelMessageListenerImpl(sess);
-	
-	      cons.setMessageListener(listener);
-	
-	      MessageProducer prod = sessSend.createProducer(queue1);
-	      TextMessage m1 = sess.createTextMessage("a");
-	      TextMessage m2 = sess.createTextMessage("b");
-	      TextMessage m3 = sess.createTextMessage("c");
-	
-	      prod.send(m1);
-	      prod.send(m2);
-	      prod.send(m3);
-	
-	      listener.waitForMessages();
-	
-	      assertFalse(listener.message, listener.failed);
-	
-	      conn.close();
-	      
-	      conn = null;
-	   }
-	   finally
-	   {
-	   	if (conn != null)
-	   	{
-	   		conn.close();
-	   	}
-	   }
-   }
-
-   public void testExceptionMessageListener2() throws Exception
-   {
-   	Connection conn = null;
-      
-      try
-      {	      
-	      conn = cf.createConnection();
-
-	      conn.start();
-	
-	      Session sessSend = conn.createSession(false, Session.AUTO_ACKNOWLEDGE);
-	
-	      Session sess = conn.createSession(false, Session.DUPS_OK_ACKNOWLEDGE);
-	
-	      MessageConsumer cons = sess.createConsumer(queue1);
-	
-	      ExceptionRedelMessageListenerImpl listener = new ExceptionRedelMessageListenerImpl(sess);
-	
-	      cons.setMessageListener(listener);
-	
-	      MessageProducer prod = sessSend.createProducer(queue1);
-	      TextMessage m1 = sess.createTextMessage("a");
-	      TextMessage m2 = sess.createTextMessage("b");
-	      TextMessage m3 = sess.createTextMessage("c");
-	
-	      prod.send(m1);
-	      prod.send(m2);
-	      prod.send(m3);
-	
-	      listener.waitForMessages();
-	
-	      assertFalse(listener.message, listener.failed);
-	  	
-	
-	      conn.close();
-	      
-	      conn = null;
-	   }
-	   finally
-	   {
-	   	if (conn != null)
-	   	{
-	   		conn.close();
-	   	}
-	   }
-   }
-
    public void testExceptionMessageListener3() throws Exception
    {
    	Connection conn = null;