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

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

Author: ataylor
Date: 2009-08-04 11:03:14 -0400 (Tue, 04 Aug 2009)
New Revision: 7664

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerTest.java
Log:
added test

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerTest.java	2009-08-04 13:43:46 UTC (rev 7663)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ConsumerTest.java	2009-08-04 15:03:14 UTC (rev 7664)
@@ -222,4 +222,36 @@
                    ((Queue)server.getPostOffice().getBinding(QUEUE).getBindable()).getMessageCount());
    }
 
+   /*public void testAcksWithSmallSendWindow() throws Exception
+   {
+      ClientSessionFactory sf = createInVMFactory();
+
+      ClientSession session = sf.createSession(false, true, true);
+
+      session.createQueue(QUEUE, QUEUE, null, false);
+
+      ClientProducer producer = session.createProducer(QUEUE);
+
+      final int numMessages = 1000;
+
+      for (int i = 0; i < numMessages; i++)
+      {
+         ClientMessage message = createTextMessage("m" + i, session);
+         producer.send(message);
+      }
+      System.out.println("-----------------------------------------------------------------------------");
+      ClientSessionFactory sfReceive = createInVMFactory();
+      sfReceive.setProducerWindowSize(100);
+      sfReceive.setAckBatchSize(-1);
+      ClientSession sessionRec = sfReceive.createSession(false, true, true);
+      ClientConsumer consumer = sessionRec.createConsumer(QUEUE);
+      sessionRec.start();
+      for (int i = 0; i < numMessages; i++)
+      {
+         ClientMessage message2 = consumer.receive(1000);
+         System.out.println("message2 = " + message2);
+         message2.acknowledge();
+      }
+   }*/
+
 }