[hornetq-commits] JBoss hornetq SVN: r9090 - in trunk/tests/src/org/hornetq/tests/integration: remoting and 1 other directory.
Author: timfox
Date: 2010-04-10 05:40:22 -0400 (Sat, 10 Apr 2010)
New Revision: 9090
Modified:
trunk/tests/src/org/hornetq/tests/integration/client/QueueBrowserTest.java
trunk/tests/src/org/hornetq/tests/integration/remoting/BatchDelayTest.java
Log:
fixed test and added a new browser test
Modified: trunk/tests/src/org/hornetq/tests/integration/client/QueueBrowserTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/client/QueueBrowserTest.java 2010-04-09
20:15:18 UTC (rev 9089)
+++ trunk/tests/src/org/hornetq/tests/integration/client/QueueBrowserTest.java 2010-04-10
09:40:22 UTC (rev 9090)
@@ -355,5 +355,51 @@
sf.close();
}
+
+ public void testBrowseWithZeroConsumerWindowSize() throws Exception
+ {
+ ClientSessionFactory sf = createInVMFactory();
+
+ sf.setConsumerWindowSize(0);
+ ClientSession session = sf.createSession(false, true, true);
+
+ session.createQueue(QUEUE, QUEUE, null, false);
+
+ ClientProducer producer = session.createProducer(QUEUE);
+
+ final int numMessages = 100;
+
+ byte[] bytes = new byte[240];
+
+ for (int i = 0; i < numMessages; i++)
+ {
+ ClientMessage message = session.createMessage(false);
+
+ message.getBodyBuffer().writeBytes(bytes);
+
+ message.putIntProperty("foo", i);
+
+ producer.send(message);
+ }
+
+ //Create a normal non browsing consumer
+ ClientConsumer consumer = session.createConsumer(QUEUE);
+
+ session.start();
+
+ ClientConsumer browser = session.createConsumer(QUEUE, true);
+
+ for (int i = 0; i < numMessages; i++)
+ {
+ ClientMessage message2 = browser.receive(1000);
+
+ assertEquals(i, message2.getIntProperty("foo").intValue());
+ }
+
+ session.close();
+
+ sf.close();
+ }
+
}
Modified: trunk/tests/src/org/hornetq/tests/integration/remoting/BatchDelayTest.java
===================================================================
--- trunk/tests/src/org/hornetq/tests/integration/remoting/BatchDelayTest.java 2010-04-09
20:15:18 UTC (rev 9089)
+++ trunk/tests/src/org/hornetq/tests/integration/remoting/BatchDelayTest.java 2010-04-10
09:40:22 UTC (rev 9090)
@@ -157,20 +157,12 @@
ClientMessage msg = session.createMessage(false);
- long start = System.currentTimeMillis();
-
prod.send(msg);
msg = cons.receive(10000);
assertNotNull(msg);
- long end = System.currentTimeMillis();
-
- //This will be delayed
-
- assertTrue(end - start > DELAY);
-
msg.acknowledge();
sf.close();