akka.actor.mailbox.filebased.filequeue
Class Journal
java.lang.Object
akka.actor.mailbox.filebased.filequeue.Journal
public class Journal
- extends java.lang.Object
Codes for working with the journal file for a PersistentQueue.
Constructor Summary |
Journal(java.lang.String queuePath,
scala.Function0<java.lang.Object> syncJournal,
LoggingAdapter log)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Journal
public Journal(java.lang.String queuePath,
scala.Function0<java.lang.Object> syncJournal,
LoggingAdapter log)
size
public long size()
open
public void open()
roll
public void roll(int xid,
scala.collection.immutable.List<QItem> openItems,
scala.collection.Iterable<QItem> queue)
close
public void close()
erase
public void erase()
inReadBehind
public boolean inReadBehind()
isReplaying
public boolean isReplaying()
add
public void add(QItem item)
remove
public void remove()
removeTentative
public void removeTentative()
unremove
public void unremove(int xid)
confirmRemove
public void confirmRemove(int xid)
startReadBehind
public void startReadBehind()
fillReadBehind
public void fillReadBehind(scala.Function1<QItem,scala.runtime.BoxedUnit> f)
replay
public void replay(java.lang.String name,
scala.Function1<JournalItem,scala.runtime.BoxedUnit> f)
readJournalEntry
public scala.Tuple2<JournalItem,java.lang.Object> readJournalEntry(java.nio.channels.FileChannel in)
walk
public java.lang.Object walk()