[hornetq-commits] JBoss hornetq SVN: r10081 - trunk/src/main/org/hornetq/core/persistence/impl/nullpm.

[do-not-reply at jboss.org]

Author: clebert.suconic at jboss.com
Date: 2010-12-28 12:31:02 -0500 (Tue, 28 Dec 2010)
New Revision: 10081

Modified:
   trunk/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java
Log:
fixing one test

Modified: trunk/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java
===================================================================
--- trunk/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2010-12-28 00:44:28 UTC (rev 10080)
+++ trunk/src/main/org/hornetq/core/persistence/impl/nullpm/NullStorageManager.java	2010-12-28 17:31:02 UTC (rev 10081)
@@ -21,8 +21,6 @@
 
 import javax.transaction.xa.Xid;
 
-import org.hornetq.api.core.HornetQBuffer;
-import org.hornetq.api.core.HornetQBuffers;
 import org.hornetq.api.core.Pair;
 import org.hornetq.api.core.SimpleString;
 import org.hornetq.core.journal.IOAsyncTask;
@@ -61,6 +59,52 @@
    private final AtomicLong idSequence = new AtomicLong(0);
 
    private volatile boolean started;
+   
+   private static final OperationContext dummyContext = new OperationContext()
+   {
+      
+      public void onError(int errorCode, String errorMessage)
+      {
+      }
+      
+      public void done()
+      {
+      }
+      
+      public void storeLineUp()
+      {
+      }
+      
+      public boolean waitCompletion(long timeout) throws Exception
+      {
+         return true;
+      }
+      
+      public void waitCompletion() throws Exception
+      {
+      }
+      
+      public void replicationLineUp()
+      {
+      }
+      
+      public void replicationDone()
+      {
+      }
+      
+      public void pageSyncLineUp()
+      {
+      }
+      
+      public void pageSyncDone()
+      {
+      }
+      
+      public void executeOnCompletion(IOAsyncTask runnable)
+      {
+         runnable.done();
+      }
+   };
 
    public void sync()
    {
@@ -352,7 +396,7 @@
     */
    public OperationContext getContext()
    {
-      return null;
+      return dummyContext;
    }
 
    /* (non-Javadoc)
@@ -360,7 +404,7 @@
     */
    public OperationContext newContext(final Executor executor)
    {
-      return null;
+      return dummyContext;
    }
 
    /* (non-Javadoc)
@@ -440,8 +484,6 @@
     */
    public void storeCursorAcknowledge(long queueID, PagePosition position)
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -449,8 +491,6 @@
     */
    public void storeCursorAcknowledgeTransactional(long txID, long queueID, PagePosition position)
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -458,8 +498,6 @@
     */
    public void deleteCursorAcknowledgeTransactional(long txID, long ackID) throws Exception
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -467,8 +505,6 @@
     */
    public void updatePageTransaction(PageTransactionInfo pageTransaction, int depage) throws Exception
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -476,7 +512,6 @@
     */
    public long storePageCounter(long txID, long queueID, long value) throws Exception
    {
-      // TODO Auto-generated method stub
       return 0;
    }
 
@@ -485,8 +520,6 @@
     */
    public void deleteIncrementRecord(long txID, long recordID) throws Exception
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -494,8 +527,6 @@
     */
    public void deletePageCounter(long txID, long recordID) throws Exception
    {
-      // TODO Auto-generated method stub
-      
    }
 
    /* (non-Javadoc)
@@ -503,7 +534,6 @@
     */
    public long storePageCounterInc(long txID, long queueID, int add) throws Exception
    {
-      // TODO Auto-generated method stub
       return 0;
    }
 
@@ -512,7 +542,6 @@
     */
    public long storePageCounterInc(long queueID, int add) throws Exception
    {
-      // TODO Auto-generated method stub
       return 0;
    }