[jboss-cvs] JBoss Messaging SVN: r5914 - in trunk/tests/src/org/jboss/messaging/tests: soak/chunk and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2009-02-20 17:49:21 -0500 (Fri, 20 Feb 2009)
New Revision: 5914

Modified:
   trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/ChunkTestBase.java
   trunk/tests/src/org/jboss/messaging/tests/soak/chunk/MessageChunkSoakTest.java
Log:
Playing with two different settings on the SessionFactories (Consumer and Producers with different minLargeMessageSizes)

Modified: trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/ChunkTestBase.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/ChunkTestBase.java	2009-02-20 19:58:52 UTC (rev 5913)
+++ trunk/tests/src/org/jboss/messaging/tests/integration/chunkmessage/ChunkTestBase.java	2009-02-20 22:49:21 UTC (rev 5914)
@@ -35,6 +35,7 @@
 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.ClientSessionFactoryImpl;
 import org.jboss.messaging.core.exception.MessagingException;
 import org.jboss.messaging.core.logging.Logger;
 import org.jboss.messaging.core.message.impl.MessageImpl;
@@ -103,6 +104,8 @@
                  waitOnConsumer,
                  delayDelivery,
                  -1,
+                 100 * 1024,
+                 10 * 1024,
                  false);
    }
 
@@ -116,6 +119,8 @@
                              final int waitOnConsumer,
                              final long delayDelivery,
                              final int producerWindow,
+                             final int minSizeProducer,
+                             final int minSizeConsumer,
                              final boolean testTime) throws Exception
    {
 
@@ -139,6 +144,8 @@
          {
             sf.setSendWindowSize(producerWindow);
          }
+         
+         sf.setMinLargeMessageSize(minSizeProducer);
 
          ClientSession session = sf.createSession(null, null, false, true, false, preAck, 0);
 
@@ -214,6 +221,9 @@
             sf = createInVMFactory();
          }
 
+         
+         sf.setMinLargeMessageSize(minSizeConsumer);
+
          session = sf.createSession(null, null, false, true, true, preAck, 0);
 
          ClientConsumer consumer = null;
@@ -222,8 +232,6 @@
          for (int iteration = (testBrowser ? 0 : 1); iteration < 2; iteration++)
          {
 
-            System.out.println("Iteration: " + iteration);
-
             // first time with a browser
             if (realFiles)
             {

Modified: trunk/tests/src/org/jboss/messaging/tests/soak/chunk/MessageChunkSoakTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/soak/chunk/MessageChunkSoakTest.java	2009-02-20 19:58:52 UTC (rev 5913)
+++ trunk/tests/src/org/jboss/messaging/tests/soak/chunk/MessageChunkSoakTest.java	2009-02-20 22:49:21 UTC (rev 5914)
@@ -22,6 +22,7 @@
 
 package org.jboss.messaging.tests.soak.chunk;
 
+import org.jboss.messaging.core.client.impl.ClientSessionFactoryImpl;
 import org.jboss.messaging.tests.integration.chunkmessage.ChunkTestBase;
 
 /**
@@ -48,7 +49,19 @@
 
    public void testMessageChunkFilePersistence1G() throws Exception
    {
-      testChunks(true, true, false, true, false, 2, 268435456, 300000, 0, -1, true);
+      testChunks(true,
+                 true,
+                 false,
+                 true,
+                 false,
+                 2,
+                 268435456,
+                 300000,
+                 0,
+                 -1,
+                 ClientSessionFactoryImpl.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
+                 ClientSessionFactoryImpl.DEFAULT_MIN_LARGE_MESSAGE_SIZE,
+                 true);
    }
 
    // Package protected ---------------------------------------------