Author: clebert.suconic(a)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();