raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

Added more comments for the mailboxfactory

Browse source
This commit is contained in:
Viktor Klang 2010-09-08 18:15:45 +02:00
parent fe461fdd45
commit 45bf7c72cd
1 changed files with 3 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-actor/src/main/scala/dispatch/MessageHandling.scala
View file

@ -83,7 +83,7 @@ case class MailboxConfig(capacity: Int, pushTimeOut: Option[Duration], blockingD
def newMailbox(bounds: Int = capacity,
pushTime: Option[Duration] = pushTimeOut,
blockDequeue: Boolean = blockingDequeue) : MessageQueue = {
if (bounds <= 0) {
if (bounds <= 0) { //UNBOUNDED: Will never block enqueue and optionally blocking dequeue
new LinkedTransferQueue[MessageInvocation] with MessageQueue {
def enqueue(handle: MessageInvocation): Unit = this add handle
def dequeue(): MessageInvocation = {
@ -92,7 +92,7 @@ case class MailboxConfig(capacity: Int, pushTimeOut: Option[Duration], blockingD
}
}
}
else if (pushTime.isDefined) {
else if (pushTime.isDefined) { //BOUNDED: Timeouted enqueue with MessageQueueAppendFailedException and optionally blocking dequeue
val time = pushTime.get
new BoundedTransferQueue[MessageInvocation](bounds) with MessageQueue {
def enqueue(handle: MessageInvocation) {
@ -106,7 +106,7 @@ case class MailboxConfig(capacity: Int, pushTimeOut: Option[Duration], blockingD
}
}
}
else {
else { //BOUNDED: Blocking enqueue and optionally blocking dequeue
new LinkedBlockingQueue[MessageInvocation](bounds) with MessageQueue {
def enqueue(handle: MessageInvocation): Unit = this put handle
def dequeue(): MessageInvocation = {