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

=con Harden ClusterShardingSpec some more

Browse source 
* Replace sleep with awaitAssert
* Use separate probes for awaitAssert checks to avoid spill-over
  to the testActor
* Some additional cleanup
* Deliver buffered messages when HostShard is received
  Test failures showed that initial messages could be re-ordered otherwise
This commit is contained in:
Patrik Nordwall 2014-08-25 10:26:28 +02:00
parent 3ca27a54ad
commit e5cd47279d
3 changed files with 37 additions and 44 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

@ -372,7 +372,7 @@ class NodeMessageQueue extends AbstractNodeQueue[Envelope] with MessageQueue wit
//Discards overflowing messages into DeadLetters
class BoundedNodeMessageQueue(capacity: Int) extends AbstractBoundedNodeQueue[Envelope](capacity)
with MessageQueue with BoundedMessageQueueSemantics with MultipleConsumerSemantics {
with MessageQueue with BoundedMessageQueueSemantics with MultipleConsumerSemantics {
final def pushTimeOut: Duration = Duration.Undefined
final def enqueue(receiver: ActorRef, handle: Envelope): Unit =