|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object akka.actor.mailbox.DurableMessageQueue akka.actor.mailbox.filebased.FileBasedMessageQueue
public class FileBasedMessageQueue
Constructor Summary | |
---|---|
FileBasedMessageQueue(ActorRef _owner,
ExtendedActorSystem _system,
FileBasedMailboxSettings settings)
|
Method Summary | |
---|---|
CircuitBreaker |
breaker()
|
void |
cleanUp(ActorRef owner,
MessageQueue deadLetters)
Called when the mailbox this queue belongs to is disposed of. |
Envelope |
dequeue()
Try to dequeue the next message from this queue, return null failing that. |
void |
enqueue(ActorRef receiver,
Envelope envelope)
Try to enqueue the message to this queue, or throw an exception. |
boolean |
hasMessages()
Indicates whether this queue is non-empty. |
int |
numberOfMessages()
Should return the current number of messages held in this queue; may always return 0 if no other value is available efficiently. |
boolean |
remove()
Completely delete the queue. |
FileBasedMailboxSettings |
settings()
|
Methods inherited from class akka.actor.mailbox.DurableMessageQueue |
---|
name, owner, ownerPath, ownerPathString, system |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface akka.actor.mailbox.DurableMessageSerialization |
---|
deserialize, serialize |
Constructor Detail |
---|
public FileBasedMessageQueue(ActorRef _owner, ExtendedActorSystem _system, FileBasedMailboxSettings settings)
Method Detail |
---|
public FileBasedMailboxSettings settings()
public CircuitBreaker breaker()
public void enqueue(ActorRef receiver, Envelope envelope)
MessageQueue
enqueue
in interface MessageQueue
receiver
- (undocumented)envelope
- (undocumented)public Envelope dequeue()
MessageQueue
dequeue
in interface MessageQueue
public int numberOfMessages()
MessageQueue
hasMessages
instead.
numberOfMessages
in interface MessageQueue
public boolean hasMessages()
MessageQueue
hasMessages
in interface MessageQueue
public boolean remove()
public void cleanUp(ActorRef owner, MessageQueue deadLetters)
MessageQueue
cleanUp
in interface MessageQueue
owner
- (undocumented)deadLetters
- (undocumented)
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |