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

#1773 bites the dust

Browse source
This commit is contained in:
Viktor Klang 2012-02-02 09:22:26 +01:00
parent 1e347bab11
commit c201d28fbb
1 changed files with 1 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor/src/main/scala/akka/dispatch/Mailbox.scala
View file

@ -303,7 +303,7 @@ trait BoundedMessageQueueSemantics extends QueueBasedMessageQueue {
final def enqueue(receiver: ActorRef, handle: Envelope) { final def enqueue(receiver: ActorRef, handle: Envelope) {
if (pushTimeOut.length > 0) { if (pushTimeOut.length > 0) {
queue.offer(handle, pushTimeOut.length, pushTimeOut.unit) || { queue.offer(handle, pushTimeOut.length, pushTimeOut.unit) || {
throw new MessageQueueAppendFailedException("Couldn't enqueue message " + handle + " to " + toString) throw new MessageQueueAppendFailedException("Couldn't enqueue message " + handle + " to " + receiver)
} }
} else queue put handle } else queue put handle
} }