org.apache.activemq.kaha.impl.async

Class DataManagerFacade

java.lang.Object

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

All Implemented Interfaces:

DataManager

public final class DataManagerFacade
extends java.lang.Object
implements DataManager

Provides a Kaha DataManager Facade to the DataManager.

Constructor Summary

Constructors

Constructor and Description
DataManagerFacade(AsyncDataManager dataManager, java.lang.String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	addInterestInFile(int file)
void	close()
void	consolidateDataFiles()
boolean	delete()
void	force()
java.lang.String	getName()
Marshaller	getRedoMarshaller()
java.lang.Object	readItem(Marshaller marshaller, StoreLocation location)
void	recoverRedoItems(RedoListener listener)
void	removeInterestInFile(int file)
void	setRedoMarshaller(Marshaller redoMarshaller)
StoreLocation	storeDataItem(Marshaller marshaller, java.lang.Object payload)
StoreLocation	storeRedoItem(java.lang.Object payload)
void	updateItem(StoreLocation location, Marshaller marshaller, java.lang.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,
                 java.lang.String name)

Method Detail

readItem

public java.lang.Object readItem(Marshaller marshaller,
                        StoreLocation location)
                          throws java.io.IOException

Specified by:

readItem in interface DataManager

Throws:

java.io.IOException

storeDataItem

public StoreLocation storeDataItem(Marshaller marshaller,
                          java.lang.Object payload)
                            throws java.io.IOException

Specified by:

storeDataItem in interface DataManager

Throws:

java.io.IOException

force

public void force()
           throws java.io.IOException

Specified by:

force in interface DataManager

Throws:

java.io.IOException

updateItem

public void updateItem(StoreLocation location,
              Marshaller marshaller,
              java.lang.Object payload)
                throws java.io.IOException

Specified by:

updateItem in interface DataManager

Throws:

java.io.IOException

close

public void close()
           throws java.io.IOException

Specified by:

close in interface DataManager

Throws:

java.io.IOException

consolidateDataFiles

public void consolidateDataFiles()
                          throws java.io.IOException

Specified by:

consolidateDataFiles in interface DataManager

Throws:

java.io.IOException

delete

public boolean delete()
               throws java.io.IOException

Specified by:

delete in interface DataManager

Throws:

java.io.IOException

addInterestInFile

public void addInterestInFile(int file)
                       throws java.io.IOException

Specified by:

addInterestInFile in interface DataManager

Throws:

java.io.IOException

removeInterestInFile

public void removeInterestInFile(int file)
                          throws java.io.IOException

Specified by:

removeInterestInFile in interface DataManager

Throws:

java.io.IOException

recoverRedoItems

public void recoverRedoItems(RedoListener listener)
                      throws java.io.IOException

Specified by:

recoverRedoItems in interface DataManager

Throws:

java.io.IOException

storeRedoItem

public StoreLocation storeRedoItem(java.lang.Object payload)
                            throws java.io.IOException

Specified by:

storeRedoItem in interface DataManager

Throws:

java.io.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 java.lang.String getName()

Specified by:

getName in interface DataManager