akka.actor.mailbox.filebased.filequeue
Class Journal

java.lang.Object
  extended by 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)
           
 
Method Summary
 void add(QItem item)
           
 void close()
           
 void confirmRemove(int xid)
           
 void erase()
           
 void fillReadBehind(scala.Function1<QItem,scala.runtime.BoxedUnit> f)
           
 boolean inReadBehind()
           
 boolean isReplaying()
           
 void open()
           
 scala.Tuple2<JournalItem,java.lang.Object> readJournalEntry(java.nio.channels.FileChannel in)
           
 void remove()
           
 void removeTentative()
           
 void replay(java.lang.String name, scala.Function1<JournalItem,scala.runtime.BoxedUnit> f)
           
 void roll(int xid, scala.collection.immutable.List<QItem> openItems, scala.collection.Iterable<QItem> queue)
           
 long size()
           
 void startReadBehind()
           
 void unremove(int xid)
           
 java.lang.Object walk()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

Journal

public Journal(java.lang.String queuePath,
               scala.Function0<java.lang.Object> syncJournal,
               LoggingAdapter log)
Method Detail

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()