[hornetq-commits] JBoss hornetq SVN: r8370 - in branches/ClebertCallback: tests/src/org/hornetq/tests/integration/largemessage and 1 other directory.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2009-11-22 21:51:06 -0500 (Sun, 22 Nov 2009)
New Revision: 8370

Modified:
   branches/ClebertCallback/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
   branches/ClebertCallback/tests/src/org/hornetq/tests/integration/largemessage/ServerLargeMessageTest.java
Log:
tweaks

Modified: branches/ClebertCallback/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java
===================================================================
--- branches/ClebertCallback/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-23 02:04:55 UTC (rev 8369)
+++ branches/ClebertCallback/src/main/org/hornetq/core/persistence/impl/journal/OperationContextImpl.java	2009-11-23 02:51:06 UTC (rev 8370)
@@ -211,6 +211,8 @@
       {
          public void run()
          {
+            // If any IO is done inside the callback, it needs to be done on a new context
+            clearContext();
             task.done();
             executorsPending.decrementAndGet();
          }

Modified: branches/ClebertCallback/tests/src/org/hornetq/tests/integration/largemessage/ServerLargeMessageTest.java
===================================================================
--- branches/ClebertCallback/tests/src/org/hornetq/tests/integration/largemessage/ServerLargeMessageTest.java	2009-11-23 02:04:55 UTC (rev 8369)
+++ branches/ClebertCallback/tests/src/org/hornetq/tests/integration/largemessage/ServerLargeMessageTest.java	2009-11-23 02:51:06 UTC (rev 8370)
@@ -50,7 +50,7 @@
 
    // Public --------------------------------------------------------
    
-   protected void setup() throws Exception
+   protected void setUp() throws Exception
    {
       super.setUp();