Home » activemq-parent-5.3.1-source-release » org.apache » activemq » kaha » impl » data » [javadoc | source]
org.apache.activemq.kaha.impl.data
public final class: DataManagerImpl [javadoc | source]
java.lang.Object
   org.apache.activemq.kaha.impl.data.DataManagerImpl

All Implemented Interfaces:
    DataManager

Manages DataFiles
Field Summary
public static final  int ITEM_HEAD_SIZE     
public static final  byte DATA_ITEM_TYPE     
public static final  byte REDO_ITEM_TYPE     
public static final  long MAX_FILE_LENGTH     
Constructor:
 public DataManagerImpl(File dir,
    String name,
    AtomicLong storeSize) 
Method from org.apache.activemq.kaha.impl.data.DataManagerImpl Summary:
addInterestInFile,   addInterestInFile,   close,   consolidateDataFiles,   createReader,   delete,   findSpaceForData,   force,   getDataFile,   getMaxFileLength,   getName,   getReader,   getRedoMarshaller,   getWriter,   readItem,   recoverRedoItems,   removeInterestInFile,   removeInterestInFile,   setMaxFileLength,   setReader,   setRedoMarshaller,   setWriter,   storeDataItem,   storeRedoItem,   toString,   updateItem
Methods from java.lang.Object:
clone,   equals,   finalize,   getClass,   hashCode,   notify,   notifyAll,   toString,   wait,   wait,   wait
Method from org.apache.activemq.kaha.impl.data.DataManagerImpl Detail:
 public synchronized  void addInterestInFile(int file) throws IOException 
 synchronized  void addInterestInFile(DataFile dataFile) 
 public synchronized  void close() throws IOException 
 public synchronized  void consolidateDataFiles() throws IOException 
 protected synchronized SyncDataFileReader createReader() 
 public synchronized boolean delete() throws IOException 
 synchronized DataFile findSpaceForData(DataItem item) throws IOException 
 public synchronized  void force() throws IOException 
 DataFile getDataFile(StoreLocation item) throws IOException 
 public long getMaxFileLength() 
 public String getName() 
 public synchronized SyncDataFileReader getReader() 
 public Marshaller getRedoMarshaller() 
 public synchronized SyncDataFileWriter getWriter() 
 public synchronized Object readItem(Marshaller marshaller,
    StoreLocation item) throws IOException 
 public synchronized  void recoverRedoItems(RedoListener listener) throws IOException 
 public synchronized  void removeInterestInFile(int file) throws IOException 
 synchronized  void removeInterestInFile(DataFile dataFile) throws IOException 
 public  void setMaxFileLength(long maxFileLength) 
 public synchronized  void setReader(SyncDataFileReader reader) 
 public  void setRedoMarshaller(Marshaller redoMarshaller) 
 public synchronized  void setWriter(SyncDataFileWriter writer) 
 public synchronized StoreLocation storeDataItem(Marshaller marshaller,
    Object payload) throws IOException 
 public synchronized StoreLocation storeRedoItem(Object payload) throws IOException 
 public String toString() 
 public synchronized  void updateItem(StoreLocation location,
    Marshaller marshaller,
    Object payload) throws IOException