|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.mailbox.filebased.filequeue.QueueCollection
public class QueueCollection
Constructor Summary | |
---|---|
QueueCollection(java.lang.String queueFolder,
FileBasedMailboxSettings settings,
LoggingAdapter log)
|
Method Summary | |
---|---|
boolean |
add(java.lang.String key,
byte[] item)
|
boolean |
add(java.lang.String key,
byte[] item,
int expiry)
Add an item to a named queue. |
void |
confirmRemove(java.lang.String key,
int xid)
|
long |
currentBytes()
|
long |
currentItems()
|
void |
delete(java.lang.String name)
|
java.lang.String[] |
dumpConfig(java.lang.String key)
|
void |
flush(java.lang.String key)
|
int |
flushAllExpired()
|
int |
flushExpired(java.lang.String name)
|
void |
loadQueues()
|
scala.Option<PersistentQueue> |
queue(java.lang.String name)
Get a named queue, creating it if necessary. |
Counter |
queueHits()
|
Counter |
queueMisses()
|
scala.collection.immutable.List<java.lang.String> |
queueNames()
|
scala.Option<byte[]> |
receive(java.lang.String key)
|
void |
remove(java.lang.String key,
int timeout,
boolean transaction,
boolean peek,
scala.Function1<scala.Option<QItem>,scala.runtime.BoxedUnit> f)
Retrieve an item from a queue and pass it to a continuation. |
void |
shutdown()
Shutdown this queue collection. |
scala.Tuple2<java.lang.String,java.lang.String>[] |
stats(java.lang.String key)
|
Counter |
totalAdded()
|
void |
unremove(java.lang.String key,
int xid)
|
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
public QueueCollection(java.lang.String queueFolder, FileBasedMailboxSettings settings, LoggingAdapter log)
Method Detail |
---|
public Counter totalAdded()
public Counter queueHits()
public Counter queueMisses()
public void loadQueues()
public scala.collection.immutable.List<java.lang.String> queueNames()
public long currentItems()
public long currentBytes()
public scala.Option<PersistentQueue> queue(java.lang.String name)
name
- (undocumented)
public boolean add(java.lang.String key, byte[] item, int expiry)
key
- (undocumented)item
- (undocumented)expiry
- (undocumented)
public boolean add(java.lang.String key, byte[] item)
public void remove(java.lang.String key, int timeout, boolean transaction, boolean peek, scala.Function1<scala.Option<QItem>,scala.runtime.BoxedUnit> f)
key
- (undocumented)timeout
- (undocumented)transaction
- (undocumented)peek
- (undocumented)f
- (undocumented)public scala.Option<byte[]> receive(java.lang.String key)
public void unremove(java.lang.String key, int xid)
public void confirmRemove(java.lang.String key, int xid)
public void flush(java.lang.String key)
public void delete(java.lang.String name)
public int flushExpired(java.lang.String name)
public int flushAllExpired()
public scala.Tuple2<java.lang.String,java.lang.String>[] stats(java.lang.String key)
public java.lang.String[] dumpConfig(java.lang.String key)
public void shutdown()
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |