Socket not closed on binding fail, causing the ActorSystem to not shutdown

[damienlevin]

package com.mdialog.test

import akka.dispatch._
import akka.actor._
import akka.pattern._
import akka.util._

import scala.concurrent.duration._
import scala.concurrent._
import ExecutionContext.Implicits.global

object Test extends App {

val system = ActorSystem("test")
system.registerOnTermination {
println("ActorSystem.registerOnTermination")
}

val account = system.actorOf(Props[TestActor])

account ! "pouf"

Thread.sleep(5000)

println("Shutdown")
system.shutdown()

}

class TestActor extends Actor {

val endpointA = "tcp://127.0.0.1:%s" format { val s = new java.net.ServerSocket(0); try s.getLocalPort finally s.close() }
val endpointB = "tcp://127.0.0.1:%s" format { val s = new java.net.ServerSocket(0); try s.getLocalPort finally s.close() }

def receive = {
case _ ⇒
val socketA = zeromq.ZeroMQExtension.get(context.system).newSocket(zeromq.SocketType.Pub, zeromq.Listener(self), zeromq.Linger(0), zeromq.Bind(endpointA))
val socketB = zeromq.ZeroMQExtension.get(context.system).newSocket(zeromq.SocketType.Pull, zeromq.Listener(self), zeromq.Linger(0), zeromq.Bind(endpointB))
val socketC = zeromq.ZeroMQExtension.get(context.system).newSocket(zeromq.SocketType.Pull, zeromq.Listener(self), zeromq.Linger(0), zeromq.Bind(endpointB))
}

override def postStop() {
println("Stopping TestActor...")
}
}

[chrisdinn]

Fixed by 2f32205