org.apache.activemq.kaha.impl.async
Class DataManagerFacade

java.lang.Object
  extended by org.apache.activemq.kaha.impl.async.DataManagerFacade
All Implemented Interfaces:
DataManager

public final class DataManagerFacade
extends Object
implements DataManager

Provides a Kaha DataManager Facade to the DataManager.


Constructor Summary
DataManagerFacade(AsyncDataManager dataManager, String name)
           
 
Method Summary
 void addInterestInFile(int file)
           
 void close()
           
 void consolidateDataFiles()
           
 boolean delete()
           
 void force()
           
 String getName()
           
 Marshaller getRedoMarshaller()
           
 Object readItem(Marshaller marshaller, StoreLocation location)
           
 void recoverRedoItems(RedoListener listener)
           
 void removeInterestInFile(int file)
           
 void setRedoMarshaller(Marshaller redoMarshaller)
           
 StoreLocation storeDataItem(Marshaller marshaller, Object payload)
           
 StoreLocation storeRedoItem(Object payload)
           
 void updateItem(StoreLocation location, Marshaller marshaller, Object payload)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DataManagerFacade

public DataManagerFacade(AsyncDataManager dataManager,
                         String name)
Method Detail

readItem

public Object readItem(Marshaller marshaller,
                       StoreLocation location)
                throws IOException
Specified by:
readItem in interface DataManager
Throws:
IOException

storeDataItem

public StoreLocation storeDataItem(Marshaller marshaller,
                                   Object payload)
                            throws IOException
Specified by:
storeDataItem in interface DataManager
Throws:
IOException

force

public void force()
           throws IOException
Specified by:
force in interface DataManager
Throws:
IOException

updateItem

public void updateItem(StoreLocation location,
                       Marshaller marshaller,
                       Object payload)
                throws IOException
Specified by:
updateItem in interface DataManager
Throws:
IOException

close

public void close()
           throws IOException
Specified by:
close in interface DataManager
Throws:
IOException

consolidateDataFiles

public void consolidateDataFiles()
                          throws IOException
Specified by:
consolidateDataFiles in interface DataManager
Throws:
IOException

delete

public boolean delete()
               throws IOException
Specified by:
delete in interface DataManager
Throws:
IOException

addInterestInFile

public void addInterestInFile(int file)
                       throws IOException
Specified by:
addInterestInFile in interface DataManager
Throws:
IOException

removeInterestInFile

public void removeInterestInFile(int file)
                          throws IOException
Specified by:
removeInterestInFile in interface DataManager
Throws:
IOException

recoverRedoItems

public void recoverRedoItems(RedoListener listener)
                      throws IOException
Specified by:
recoverRedoItems in interface DataManager
Throws:
IOException

storeRedoItem

public StoreLocation storeRedoItem(Object payload)
                            throws IOException
Specified by:
storeRedoItem in interface DataManager
Throws:
IOException

getRedoMarshaller

public Marshaller getRedoMarshaller()
Specified by:
getRedoMarshaller in interface DataManager

setRedoMarshaller

public void setRedoMarshaller(Marshaller redoMarshaller)
Specified by:
setRedoMarshaller in interface DataManager

getName

public String getName()
Specified by:
getName in interface DataManager


Copyright © 2005-2012 The Apache Software Foundation. All Rights Reserved.