[jboss-cvs] JBoss Messaging SVN: r5172 - in trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl: fakes and 1 other directory.

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

Author: clebert.suconic at jboss.com
Date: 2008-10-23 10:55:56 -0400 (Thu, 23 Oct 2008)
New Revision: 5172

Modified:
   trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalAsyncTest.java
   trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java
Log:
Just cleanup

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalAsyncTest.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalAsyncTest.java	2008-10-23 14:51:40 UTC (rev 5171)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/JournalAsyncTest.java	2008-10-23 14:55:56 UTC (rev 5172)
@@ -32,7 +32,6 @@
 import org.jboss.messaging.core.journal.impl.JournalImpl;
 import org.jboss.messaging.tests.unit.core.journal.impl.fakes.FakeSequentialFileFactory;
 import org.jboss.messaging.tests.unit.core.journal.impl.fakes.SimpleEncoding;
-import org.jboss.messaging.tests.unit.core.journal.impl.fakes.FakeSequentialFileFactory.FakeSequentialFile;
 import org.jboss.messaging.tests.util.UnitTestCase;
 
 public class JournalAsyncTest extends UnitTestCase
@@ -119,12 +118,14 @@
 
       final CountDownLatch latch = new CountDownLatch(11);
 
-      factory.setHoldCallbacks(true, new FakeSequentialFileFactory.ListenerHoldCallback(){
+      factory.setHoldCallbacks(true, new FakeSequentialFileFactory.ListenerHoldCallback()
+      {
 
-         public void callbackAdded(ByteBuffer bytes)
+         public void callbackAdded(final ByteBuffer bytes)
          {
             latch.countDown();
-         }});
+         }
+      });
 
       class LocalThread extends Thread
       {
@@ -181,14 +182,15 @@
 
       final CountDownLatch latch = new CountDownLatch(11);
 
-      factory.setHoldCallbacks(true, new FakeSequentialFileFactory.ListenerHoldCallback(){
+      factory.setHoldCallbacks(true, new FakeSequentialFileFactory.ListenerHoldCallback()
+      {
 
-         public void callbackAdded(ByteBuffer bytes)
+         public void callbackAdded(final ByteBuffer bytes)
          {
             latch.countDown();
-         }});
+         }
+      });
 
-
       class LocalThread extends Thread
       {
          Exception e;

Modified: trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java
===================================================================
--- trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java	2008-10-23 14:51:40 UTC (rev 5171)
+++ trunk/tests/src/org/jboss/messaging/tests/unit/core/journal/impl/fakes/FakeSequentialFileFactory.java	2008-10-23 14:55:56 UTC (rev 5172)
@@ -57,7 +57,7 @@
    private final boolean supportsCallback;
 
    private volatile boolean holdCallbacks;
-   
+
    private ListenerHoldCallback holdCallbackListener;
 
    private volatile boolean generateErrors;
@@ -72,7 +72,7 @@
    {
       this.alignment = alignment;
       this.supportsCallback = supportsCallback;
-      callbacksInHold =  new ArrayList<CallbackRunnable>();
+      callbacksInHold = new ArrayList<CallbackRunnable>();
    }
 
    public FakeSequentialFileFactory()
@@ -173,7 +173,8 @@
       return holdCallbacks;
    }
 
-   public synchronized void setHoldCallbacks(final boolean holdCallbacks, final ListenerHoldCallback holdCallbackListener)
+   public synchronized void setHoldCallbacks(final boolean holdCallbacks,
+                                             final ListenerHoldCallback holdCallbackListener)
    {
       this.holdCallbacks = holdCallbacks;
       this.holdCallbackListener = holdCallbackListener;
@@ -235,11 +236,11 @@
    // Inner classes -------------------------------------------------
 
    /** This listener will return a message to the test with each callback added */
-   public static interface ListenerHoldCallback 
+   public static interface ListenerHoldCallback
    {
       public void callbackAdded(final ByteBuffer bytes);
    }
-   
+
    private class CallbackRunnable implements Runnable
    {
 
@@ -515,7 +516,7 @@
        * @param bytes
        * @param action
        */
-      private void addCallback(final ByteBuffer bytes, CallbackRunnable action)
+      private void addCallback(final ByteBuffer bytes, final CallbackRunnable action)
       {
          synchronized (FakeSequentialFileFactory.this)
          {
@@ -527,7 +528,6 @@
          }
       }
 
-
       public int getAlignment() throws Exception
       {
          return alignment;