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

Bind failures are now explicitly reported instead of swallowed

Browse source
This commit is contained in:
Endre Sándor Varga 2013-02-06 12:17:52 +01:00
parent 116dcc0e54
commit 6f0d0911a9
12 changed files with 63 additions and 58 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-actor-tests/src/test/scala/akka/io/TcpConnectionSpec.scala
View file

@ -573,7 +573,7 @@ class TcpConnectionSpec extends AkkaSpec("akka.io.tcp.register-timeout = 500ms")
commander: ActorRef): TestActorRef[TcpOutgoingConnection] = {
TestActorRef(
new TcpOutgoingConnection(Tcp(system), commander, serverAddress, localAddress, options) {
new TcpOutgoingConnection(Tcp(system), commander, Connect(serverAddress, localAddress, options)) {
override def postRestart(reason: Throwable) {
// ensure we never restart
context.stop(self)