[jboss-cvs] JBoss Messaging SVN: r6187 - trunk/tests/src/org/jboss/messaging/tests/integration/client.

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

Author: clebert.suconic at jboss.com
Date: 2009-03-26 17:35:40 -0400 (Thu, 26 Mar 2009)
New Revision: 6187

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerWindowSizeTest.java
Log:
oops.. sorry :-)

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerWindowSizeTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerWindowSizeTest.java	2009-03-26 21:34:52 UTC (rev 6186)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientConsumerWindowSizeTest.java	2009-03-26 21:35:40 UTC (rev 6187)
@@ -26,8 +26,6 @@
 import org.jboss.messaging.core.client.ClientProducer;
 import org.jboss.messaging.core.client.ClientSession;
 import org.jboss.messaging.core.client.ClientSessionFactory;
-import org.jboss.messaging.core.client.impl.ClientConsumerImpl;
-import org.jboss.messaging.core.client.impl.ClientConsumerInternal;
 import org.jboss.messaging.core.server.MessagingService;
 import org.jboss.messaging.core.server.Queue;
 import org.jboss.messaging.tests.util.ServiceTestBase;
@@ -179,81 +177,4 @@
       }
    }
 
-   public void testDeleteme() throws Exception
-   {
-      MessagingService service = createService(false);
-
-      ClientSession sessionNotUsed = null;
-      ClientSession session = null;
-
-      try
-      {
-         final int numberOfMessages = 100;
-
-         service.start();
-
-         ClientSessionFactory sf = createInVMFactory();
-         sf.setConsumerWindowSize(1);
-
-         session = sf.createSession(false, true, true);
-
-         SimpleString ADDRESS = new SimpleString("some-queue");
-
-         session.createQueue(ADDRESS, ADDRESS, true);
-
-         sessionNotUsed = sf.createSession(false, true, true);
-         sessionNotUsed.start();
-
-         session.start();
-
-         ClientConsumerInternal consNeverUsed = (ClientConsumerInternal)sessionNotUsed.createConsumer(ADDRESS);
-         // ClientConsumer consNeverUsed = sessionNotUsed.createConsumer(ADDRESS, null, -1, -1, false);
-
-         ClientConsumerInternal cons1 = (ClientConsumerInternal)session.createConsumer(ADDRESS);
-
-         ClientProducer prod = session.createProducer(ADDRESS);
-         
-         for (int i = 0; i < numberOfMessages; i++)
-         {
-            prod.send(createTextMessage(session, "Msg" + i));
-         }
-         
-         session.commit();
-         
-         Thread.sleep(1000);
-         
-         for (int i = 0; i < numberOfMessages; i++)
-         {
-            System.out.println("cons1:" + cons1.getBufferSize());
-            System.out.println("consNeverUsed:" + consNeverUsed.getBufferSize());
-
-            ClientMessage msg = cons1.receive(1000);
-            assertNotNull("expected message at i = " + i, msg);
-            msg.acknowledge();
-         }
-
-         session.commit();
-
-         // assertEquals(0, getMessageCount(service, ADDRESS.toString()));
-
-      }
-      finally
-      {
-         try
-         {
-            if (session != null)
-               session.close();
-            if (sessionNotUsed != null)
-               sessionNotUsed.close();
-         }
-         catch (Exception ignored)
-         {
-         }
-
-         if (service.isStarted())
-         {
-            service.stop();
-         }
-      }
-   }
 }