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

Merge pull request #1556 from drewhk/wip-tweak-apt-stresstest-drewhk

Browse source 
Tweaked AkkaProtocolStressSpec drop policies
This commit is contained in:
drewhk 2013-06-24 04:42:36 -07:00
commit 4c15cd3f9a
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
akka-remote/src/test/scala/akka/remote/transport/AkkaProtocolStressTest.scala
View file

@ -68,7 +68,11 @@ object AkkaProtocolStressTest {
class AkkaProtocolStressTest extends AkkaSpec(configA) with ImplicitSender with DefaultTimeout {
val systemB = ActorSystem("systemB", system.settings.config)
val systemB = ActorSystem(
"systemB",
// Retry limit for system B should be high enough that it does not trigger during this test. Otherwise
// too much messages can be dropped causing the test to fail sporadically.
ConfigFactory.parseString("akka.remote.maximum-retries-in-window = 20").withFallback(system.settings.config))
val remote = systemB.actorOf(Props(new Actor {
def receive = {
case seq: Int ⇒ sender ! seq