[jboss-cvs] JBoss Messaging SVN: r5623 - in branches/Branch_Failover_Page: tests/src/org/jboss/messaging/tests/integration/cluster/failover and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2009-01-13 16:28:25 -0500 (Tue, 13 Jan 2009)
New Revision: 5623

Modified:
   branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
   branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/LargeMessageFailoverTest.java
Log:
Fixes on largeMessage & failover

Modified: branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java
===================================================================
--- branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2009-01-13 17:32:39 UTC (rev 5622)
+++ branches/Branch_Failover_Page/src/main/org/jboss/messaging/core/client/impl/ClientConsumerImpl.java	2009-01-13 21:28:25 UTC (rev 5623)
@@ -476,9 +476,18 @@
 
          if (creditsToSend >= clientWindowSize)
          {
-            channel.send(new SessionConsumerFlowCreditMessage(id, creditsToSend));
+            final int credits = creditsToSend;
 
             creditsToSend = 0;
+
+            sessionExecutor.execute(new Runnable(){
+
+               public void run()
+               {
+                  channel.send(new SessionConsumerFlowCreditMessage(id, credits));
+               }
+               
+            });
          }
       }
    }

Modified: branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/LargeMessageFailoverTest.java
===================================================================
--- branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/LargeMessageFailoverTest.java	2009-01-13 17:32:39 UTC (rev 5622)
+++ branches/Branch_Failover_Page/tests/src/org/jboss/messaging/tests/integration/cluster/failover/LargeMessageFailoverTest.java	2009-01-13 21:28:25 UTC (rev 5623)
@@ -90,7 +90,7 @@
    //   
    public void testLargeMessageFailOnConsume() throws Exception
    {
-      testLargeMessage(2, 10, 1024 * 1024);
+      testLargeMessage(2, 100, 1024 * 1024);
    }
 
    private void testLargeMessage(final int placeToFail, final int numberOfMessages, final int messageSize) throws Exception