public final class JournalFacade extends Object implements org.apache.activeio.journal.Journal
Modifier and Type | Class and Description |
---|---|
static class |
JournalFacade.RecordLocationFacade |
Constructor and Description |
---|
JournalFacade(AsyncDataManager dataManager) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
org.apache.activeio.journal.RecordLocation |
getMark() |
org.apache.activeio.journal.RecordLocation |
getNextRecordLocation(org.apache.activeio.journal.RecordLocation location) |
org.apache.activeio.packet.Packet |
read(org.apache.activeio.journal.RecordLocation location) |
void |
setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener) |
void |
setMark(org.apache.activeio.journal.RecordLocation location,
boolean sync) |
org.apache.activeio.journal.RecordLocation |
write(org.apache.activeio.packet.Packet packet,
boolean sync) |
org.apache.activeio.journal.RecordLocation |
write(org.apache.activeio.packet.Packet packet,
Runnable onComplete) |
public JournalFacade(AsyncDataManager dataManager)
public void close() throws IOException
close
in interface org.apache.activeio.journal.Journal
IOException
public org.apache.activeio.journal.RecordLocation getMark() throws IllegalStateException
getMark
in interface org.apache.activeio.journal.Journal
IllegalStateException
public org.apache.activeio.journal.RecordLocation getNextRecordLocation(org.apache.activeio.journal.RecordLocation location) throws org.apache.activeio.journal.InvalidRecordLocationException, IOException, IllegalStateException
getNextRecordLocation
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
IOException
IllegalStateException
public org.apache.activeio.packet.Packet read(org.apache.activeio.journal.RecordLocation location) throws org.apache.activeio.journal.InvalidRecordLocationException, IOException, IllegalStateException
read
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
IOException
IllegalStateException
public void setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener) throws IllegalStateException
setJournalEventListener
in interface org.apache.activeio.journal.Journal
IllegalStateException
public void setMark(org.apache.activeio.journal.RecordLocation location, boolean sync) throws org.apache.activeio.journal.InvalidRecordLocationException, IOException, IllegalStateException
setMark
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
IOException
IllegalStateException
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet, boolean sync) throws IOException, IllegalStateException
write
in interface org.apache.activeio.journal.Journal
IOException
IllegalStateException
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet, Runnable onComplete) throws IOException, IllegalStateException
IOException
IllegalStateException
Copyright © 2005–2013 The Apache Software Foundation. All rights reserved.