1 package org.apache.activemq.kaha.impl; 2 3 import java.io.IOException ; 4 5 import org.apache.activemq.kaha.Marshaller; 6 import org.apache.activemq.kaha.StoreLocation; 7 import org.apache.activemq.kaha.impl.data.RedoListener; 8 9 public interface DataManager { 10 11 String getName(); 12 13 Object readItem(Marshaller marshaller, StoreLocation item) 14 throws IOException ; 15 16 StoreLocation storeDataItem(Marshaller marshaller, Object payload) 17 throws IOException ; 18 19 StoreLocation storeRedoItem(Object payload) throws IOException ; 20 21 void updateItem(StoreLocation location, Marshaller marshaller, 22 Object payload) throws IOException ; 23 24 void recoverRedoItems(RedoListener listener) throws IOException ; 25 26 void close() throws IOException ; 27 28 void force() throws IOException ; 29 30 boolean delete() throws IOException ; 31 32 void addInterestInFile(int file) throws IOException ; 33 34 void removeInterestInFile(int file) throws IOException ; 35 36 void consolidateDataFiles() throws IOException ; 37 38 Marshaller getRedoMarshaller(); 39 40 void setRedoMarshaller(Marshaller redoMarshaller); 41 42 } 43 | Popular Tags |