org.apache.activemq.kaha.impl.async
Class JournalFacade
java.lang.Object
org.apache.activemq.kaha.impl.async.JournalFacade
- All Implemented Interfaces:
- org.apache.activeio.journal.Journal
public final class JournalFacade
- extends java.lang.Object
- implements org.apache.activeio.journal.Journal
Provides a Journal Facade to the DataManager.
Method Summary |
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)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
JournalFacade
public JournalFacade(AsyncDataManager dataManager)
close
public void close()
throws java.io.IOException
- Specified by:
close
in interface org.apache.activeio.journal.Journal
- Throws:
java.io.IOException
getMark
public org.apache.activeio.journal.RecordLocation getMark()
throws java.lang.IllegalStateException
- Specified by:
getMark
in interface org.apache.activeio.journal.Journal
- Throws:
java.lang.IllegalStateException
getNextRecordLocation
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
- Specified by:
getNextRecordLocation
in interface org.apache.activeio.journal.Journal
- Throws:
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
read
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
- Specified by:
read
in interface org.apache.activeio.journal.Journal
- Throws:
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
setJournalEventListener
public void setJournalEventListener(org.apache.activeio.journal.JournalEventListener listener)
throws java.lang.IllegalStateException
- Specified by:
setJournalEventListener
in interface org.apache.activeio.journal.Journal
- Throws:
java.lang.IllegalStateException
setMark
public void setMark(org.apache.activeio.journal.RecordLocation location,
boolean sync)
throws org.apache.activeio.journal.InvalidRecordLocationException,
java.io.IOException,
java.lang.IllegalStateException
- Specified by:
setMark
in interface org.apache.activeio.journal.Journal
- Throws:
org.apache.activeio.journal.InvalidRecordLocationException
java.io.IOException
java.lang.IllegalStateException
write
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet,
boolean sync)
throws java.io.IOException,
java.lang.IllegalStateException
- Specified by:
write
in interface org.apache.activeio.journal.Journal
- Throws:
java.io.IOException
java.lang.IllegalStateException
write
public org.apache.activeio.journal.RecordLocation write(org.apache.activeio.packet.Packet packet,
java.lang.Runnable onComplete)
throws java.io.IOException,
java.lang.IllegalStateException
- Throws:
java.io.IOException
java.lang.IllegalStateException
Copyright © 2005-2012. All Rights Reserved.