[hornetq-commits] JBoss hornetq SVN: r9228 - trunk/tests/src/org/hornetq/tests/integration/client.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-05-11 19:40:00 -0400 (Tue, 11 May 2010)
New Revision: 9228

Modified:
   trunk/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java
Log:
https://jira.jboss.org/jira/browse/HORNETQ-385 - Adding Bill Burke's test (in disabled form ATM)

Modified: trunk/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java	2010-05-11 19:40:06 UTC (rev 9227)
+++ trunk/tests/src/org/hornetq/tests/integration/client/ConsumerWindowSizeTest.java	2010-05-11 23:40:00 UTC (rev 9228)
@@ -12,12 +12,14 @@
  */
 package org.hornetq.tests.integration.client;
 
+import java.util.ArrayList;
 import java.util.Collection;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
 
 import junit.framework.Assert;
 
+import org.hornetq.api.core.HornetQException;
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.api.core.client.ClientConsumer;
 import org.hornetq.api.core.client.ClientMessage;
@@ -69,6 +71,126 @@
       return encodeSize;
    }
 
+   
+   // https://jira.jboss.org/jira/browse/HORNETQ-385
+   public void disabled_testNoCacheWithReceiveImmediate() throws Exception
+   {
+      HornetQServer server = createServer(false, isNetty());
+      try
+      {
+         server.start();
+
+         ClientSessionFactory sf = createFactory(isNetty());
+
+         sf.setConsumerWindowSize(0);
+
+         ClientSession session = sf.createSession(false, false, false);
+         session.createQueue("testWindow", "testWindow", true);
+         session.close();
+
+         int numConsumers = 5;
+
+         ArrayList<ClientConsumer> consumers = new ArrayList<ClientConsumer>();
+         ArrayList<ClientSession> sessions = new ArrayList<ClientSession>();
+         for (int i = 0; i < numConsumers; i++)
+         {
+            System.out.println("created: " + i);
+            ClientSession session1 = sf.createSession();
+            ClientConsumer consumer = session1.createConsumer("testWindow");
+            consumers.add(consumer);
+            session1.start();
+            sessions.add(session1);
+            consumer.receiveImmediate();
+
+         }
+
+         ClientSession senderSession = sf.createSession(false, false);
+
+         ClientProducer producer = senderSession.createProducer("testWindow");
+
+         ClientMessage sent = senderSession.createMessage(true);
+         sent.putStringProperty("hello", "world");
+
+         producer.send(sent);
+
+         senderSession.commit();
+
+         senderSession.start();
+
+         ClientConsumer consumer = consumers.get(2);
+         ClientMessage received = consumer.receive(1000);
+         assertNotNull(received);
+
+         for (ClientSession tmpSess : sessions)
+         {
+            tmpSess.close();
+         }
+
+         senderSession.close();
+
+      }
+      finally
+      {
+         server.stop();
+      }
+
+   }
+   
+   // https://jira.jboss.org/jira/browse/HORNETQ-385
+   public void disabled_testNoCacheWithReceiveImmediate2() throws Exception
+   {
+      HornetQServer server = createServer(true);
+
+      try
+      {
+         server.start();
+         
+         ClientSessionFactory sf = createFactory(false);
+         sf.setConsumerWindowSize(0);
+
+         ClientSession session = sf.createSession(false, false, false);
+         session.createQueue("testReceive", "testReceive", true);
+         session.close();
+         
+         ClientSession sessionProd = sf.createSession(false, false);
+         ClientMessage msg = sessionProd.createMessage(true);
+         msg.putStringProperty("hello", "world");
+         ClientProducer prod = sessionProd.createProducer("testReceive");
+         
+         prod.send(msg);
+         sessionProd.commit();
+
+         ClientSession session1 = sf.createSession();
+         ClientConsumer consumer = session1.createConsumer("testReceive");
+         session1.start();
+
+         Thread.sleep(1000);
+         ClientMessage message = null;
+         message = consumer.receiveImmediate();
+         //message = consumer.receive(1000); // the test will pass if used receive(1000) instead of receiveImmediate
+         assertNotNull(message);
+         System.out.println(message.getStringProperty("hello"));
+         message.acknowledge();
+
+         prod.send(msg);
+         sessionProd.commit();
+
+         message = consumer.receive(1000);
+         assertNotNull(message);
+         System.out.println(message.getStringProperty("hello"));
+         message.acknowledge();
+         
+         session.close();
+         session1.close();
+         sessionProd.close();
+      }
+      finally
+      {
+         server.stop();
+      }
+   }
+   
+   
    /*
    * tests send window size. we do this by having 2 receivers on the q. since we roundrobin the consumer for delivery we
    * know if consumer 1 has received n messages then consumer 2 must have also have received n messages or at least up