public final class JournalFacade extends java.lang.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,
java.lang.Runnable onComplete) |
public JournalFacade(AsyncDataManager dataManager)
public void close() throws java.io.IOException
close
in interface org.apache.activeio.journal.Journal
java.io.IOException
public org.apache.activeio.journal.RecordLocation getMark() throws java.lang.IllegalStateException
getMark
in interface org.apache.activeio.journal.Journal
java.lang.IllegalStateException
public org.apache.activeio.journal.RecordLocation getNextRecordLocation(org.apache.activeio.journal.RecordLocation location) throws org.apache.activeio.journal.InvalidRecordLocationException, java.io.IOException, java.lang.IllegalStateException
getNextRecordLocation
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
public org.apache.activeio.packet.Packet read(org.apache.activeio.journal.RecordLocation location) throws org.apache.activeio.journal.InvalidRecordLocationException, java.io.IOException, java.lang.IllegalStateException
read
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
public void setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener) throws java.lang.IllegalStateException
setJournalEventListener
in interface org.apache.activeio.journal.Journal
java.lang.IllegalStateException
public void setMark(org.apache.activeio.journal.RecordLocation location, boolean sync) throws org.apache.activeio.journal.InvalidRecordLocationException, java.io.IOException, java.lang.IllegalStateException
setMark
in interface org.apache.activeio.journal.Journal
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet, boolean sync) throws java.io.IOException, java.lang.IllegalStateException
write
in interface org.apache.activeio.journal.Journal
java.io.IOException
java.lang.IllegalStateException
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet, java.lang.Runnable onComplete) throws java.io.IOException, java.lang.IllegalStateException
java.io.IOException
java.lang.IllegalStateException
Copyright © 2005-2017. All Rights Reserved.