[jboss-cvs] JBoss Messaging SVN: r6179 - trunk/tests/src/org/jboss/messaging/tests/integration/client.
jboss-cvs-commits at lists.jboss.org
jboss-cvs-commits at lists.jboss.org
Thu Mar 26 12:50:01 EDT 2009
Author: ataylor
Date: 2009-03-26 12:50:01 -0400 (Thu, 26 Mar 2009)
New Revision: 6179
Modified:
trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java
Log:
fixed test
Modified: trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java 2009-03-26 16:16:02 UTC (rev 6178)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/client/ClientSessionStopStartTest.java 2009-03-26 16:50:01 UTC (rev 6179)
@@ -545,7 +545,11 @@
public void testStopStartMultipleConsumers() throws Exception
{
ClientSessionFactory sf = createInVMFactory();
- sf.setConsumerWindowSize(10);
+ ClientSession tempSess = sf.createSession(false, true, true);
+ ClientMessage tempMessage = tempSess.createClientMessage(false);
+ tempMessage.setDestination(QUEUE);
+ int size = tempMessage.getEncodeSize();
+ sf.setConsumerWindowSize(size * 33);
final ClientSession session = sf.createSession(false, true, true);
session.createQueue(QUEUE, QUEUE, null, false);
@@ -553,7 +557,7 @@
ClientProducer producer = session.createProducer(QUEUE);
final int numMessages = 100;
-
+
for (int i = 0; i < numMessages; i++)
{
ClientMessage message = createTextMessage("m" + i, session);
More information about the jboss-cvs-commits
mailing list