Merge pull request #1502 from akka/wip-3390-dropped-msg-patriknw

Verify that messages are not dropped, see #3390

akka-remote-tests/src/multi-jvm/scala/akka/remote/RemoteDeliverySpec.scala

@@ -0,0 +1,77 @@
+/**
+ *  Copyright (C) 2009-2013 Typesafe Inc. <http://www.typesafe.com>
+ */
+package akka.remote
+
+import scala.concurrent.duration._
+import com.typesafe.config.ConfigFactory
+import akka.actor.Actor
+import akka.actor.ActorRef
+import akka.actor.Props
+import akka.remote.testconductor.RoleName
+import akka.remote.testkit.MultiNodeConfig
+import akka.remote.testkit.MultiNodeSpec
+import akka.remote.testkit.STMultiNodeSpec
+import akka.testkit._
+import akka.actor.ActorIdentity
+import akka.actor.Identify
+
+object RemoteDeliveryMultiJvmSpec extends MultiNodeConfig {
+  val first = role("first")
+  val second = role("second")
+  val third = role("third")
+
+  commonConfig(debugConfig(on = false).withFallback(ConfigFactory.parseString("akka.loglevel=INFO")))
+
+  case class Letter(n: Int, route: List[ActorRef])
+
+  class Postman extends Actor {
+    def receive = {
+      case Letter(n, route) ⇒ route.head ! Letter(n, route.tail)
+    }
+  }
+
+}
+
+class RemoteDeliveryMultiJvmNode1 extends RemoteDeliverySpec
+class RemoteDeliveryMultiJvmNode2 extends RemoteDeliverySpec
+class RemoteDeliveryMultiJvmNode3 extends RemoteDeliverySpec
+
+abstract class RemoteDeliverySpec
+  extends MultiNodeSpec(RemoteDeliveryMultiJvmSpec)
+  with STMultiNodeSpec with ImplicitSender {
+
+  import RemoteDeliveryMultiJvmSpec._
+
+  override def initialParticipants = roles.size
+
+  def identify(role: RoleName, actorName: String): ActorRef = {
+    system.actorSelection(node(role) / "user" / actorName) ! Identify(actorName)
+    expectMsgType[ActorIdentity].ref.get
+  }
+
+  "Remoting with TCP" must {
+
+    "not drop messages under normal circumstances" taggedAs LongRunningTest in {
+      system.actorOf(Props[Postman], "postman-" + myself.name)
+      enterBarrier("actors-started")
+
+      runOn(first) {
+        val p1 = identify(first, "postman-first")
+        val p2 = identify(second, "postman-second")
+        val p3 = identify(third, "postman-third")
+        val route = p2 :: p3 :: p2 :: p3 :: testActor :: Nil
+
+        for (n ← 1 to 500) {
+          p1 ! Letter(n, route)
+          expectMsg(5.seconds, Letter(n, Nil))
+          // in case the loop count is increased it is good with some progress feedback
+          if (n % 10000 == 0) log.info("Passed [{}]", n)
+        }
+      }
+
+      enterBarrier("after-1")
+    }
+
+  }
+}