Failing test for sending to broken connections, see #2909

akka-remote/src/test/scala/akka/remote/RemotingSpec.scala

@@ -154,6 +154,18 @@ class RemotingSpec extends AkkaSpec(RemotingSpec.cfg) with ImplicitSender with D
       }(other)
     }
 
+    "not be exhausted by sending to non existing host" in within(20.seconds) {
+      val echo = system.actorFor(RootActorPath(addr(other, "tcp")) / "user" / "echo")
+      val n = 100
+      1 to n foreach { x ⇒
+        echo ! "ping"
+        // ping messages to echo should go through even though we use many different broken connections
+        val broken = system.actorFor(s"akka.tcp://remote-sys@notexists${x}:12346/user/echo")
+        broken ! "buh"
+      }
+      receiveN(n) foreach { reply ⇒ reply must be(("pong", testActor)) }
+    }
+
     "create and supervise children on remote node" in {
       val r = system.actorOf(Props[Echo], "blub")
       r.path.toString must be === "akka.test://remote-sys@localhost:12346/remote/akka.test/RemotingSpec@localhost:12345/user/blub"