|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.mailbox.filebased.filequeue.PersistentQueue
public class PersistentQueue
Constructor Summary | |
---|---|
PersistentQueue(java.lang.String persistencePath,
java.lang.String name,
FileBasedMailboxSettings settings,
LoggingAdapter log)
|
Method Summary | ||
---|---|---|
boolean |
add(byte[] value)
|
|
boolean |
add(byte[] value,
long expiry)
Add a value to the end of the queue, transactionally. |
|
long |
bytes()
|
|
void |
close()
Close the queue's journal file. |
|
void |
configure(FileBasedMailboxSettings settings)
|
|
void |
confirmRemove(int xid)
|
|
long |
currentAge()
|
|
void |
destroyJournal()
|
|
int |
discardExpired()
|
|
OverlaySetting<java.lang.Object> |
discardOldWhenFull()
|
|
java.lang.String[] |
dumpConfig()
|
|
scala.Tuple2<java.lang.String,java.lang.String>[] |
dumpStats()
|
|
OverlaySetting<scala.Option<PersistentQueue>> |
expiredQueue()
|
|
void |
flush()
|
|
boolean |
inReadBehind()
|
|
boolean |
isClosed()
|
|
long |
journalSize()
|
|
OverlaySetting<java.lang.Object> |
keepJournal()
|
|
long |
length()
|
|
OverlaySetting<java.lang.Object> |
maxAge()
|
|
OverlaySetting<java.lang.Object> |
maxItems()
|
|
OverlaySetting<java.lang.Object> |
maxItemSize()
|
|
OverlaySetting<java.lang.Object> |
maxJournalOverflow()
|
|
OverlaySetting<java.lang.Object> |
maxJournalSize()
|
|
OverlaySetting<java.lang.Object> |
maxJournalSizeAbsolute()
|
|
OverlaySetting<java.lang.Object> |
maxMemorySize()
|
|
OverlaySetting<java.lang.Object> |
maxSize()
|
|
long |
memoryBytes()
|
|
long |
memoryLength()
|
|
java.lang.String |
name()
|
|
int |
openTransactionCount()
|
|
scala.collection.immutable.List<java.lang.Object> |
openTransactionIds()
|
|
|
overlay(scala.Function0<T> base)
|
|
void |
pauseReads()
|
|
scala.Option<QItem> |
peek()
Peek at the head item in the queue, if there is one. |
|
scala.Option<QItem> |
remove()
Remove and return an item from the queue, if there is one. |
|
scala.Option<QItem> |
remove(boolean transaction)
Remove and return an item from the queue, if there is one. |
|
void |
replayJournal()
|
|
void |
resumeReads()
|
|
FileBasedMailboxSettings |
settings()
|
|
void |
setup()
|
|
OverlaySetting<java.lang.Object> |
syncJournal()
|
|
scala.collection.immutable.List<QItem> |
toList()
|
|
long |
totalDiscarded()
|
|
long |
totalExpired()
|
|
long |
totalItems()
|
|
void |
unremove(int xid)
Return a transactionally-removed item to the queue. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public PersistentQueue(java.lang.String persistencePath, java.lang.String name, FileBasedMailboxSettings settings, LoggingAdapter log)
Method Detail |
---|
public java.lang.String name()
public FileBasedMailboxSettings settings()
public <T> OverlaySetting<T> overlay(scala.Function0<T> base)
public final OverlaySetting<java.lang.Object> maxItems()
public final OverlaySetting<java.lang.Object> maxSize()
public final OverlaySetting<java.lang.Object> maxItemSize()
public final OverlaySetting<java.lang.Object> maxAge()
public final OverlaySetting<java.lang.Object> maxJournalSize()
public final OverlaySetting<java.lang.Object> maxMemorySize()
public final OverlaySetting<java.lang.Object> maxJournalOverflow()
public final OverlaySetting<java.lang.Object> maxJournalSizeAbsolute()
public final OverlaySetting<java.lang.Object> discardOldWhenFull()
public final OverlaySetting<java.lang.Object> keepJournal()
public final OverlaySetting<java.lang.Object> syncJournal()
public final OverlaySetting<scala.Option<PersistentQueue>> expiredQueue()
public int openTransactionCount()
public scala.collection.immutable.List<java.lang.Object> openTransactionIds()
public long length()
public long totalItems()
public long bytes()
public long journalSize()
public long totalExpired()
public long currentAge()
public long totalDiscarded()
public boolean isClosed()
public long memoryLength()
public long memoryBytes()
public boolean inReadBehind()
public void configure(FileBasedMailboxSettings settings)
public java.lang.String[] dumpConfig()
public scala.Tuple2<java.lang.String,java.lang.String>[] dumpStats()
public boolean add(byte[] value, long expiry)
value
- (undocumented)expiry
- (undocumented)
public boolean add(byte[] value)
public scala.Option<QItem> peek()
public scala.Option<QItem> remove(boolean transaction)
transaction
- true if this should be considered the first part
of a transaction, to be committed or rolled back (put back at the
head of the queue)
public scala.Option<QItem> remove()
public void unremove(int xid)
xid
- (undocumented)public void confirmRemove(int xid)
public void flush()
public void close()
public void pauseReads()
public void resumeReads()
public void setup()
public void destroyJournal()
public void replayJournal()
public scala.collection.immutable.List<QItem> toList()
public final int discardExpired()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |