diff --git a/akka-zeromq/src/main/scala/akka/zeromq/ZeroMQExtension.scala b/akka-zeromq/src/main/scala/akka/zeromq/ZeroMQExtension.scala
index eabeb7373c..4eab0c1dcd 100644
--- a/akka-zeromq/src/main/scala/akka/zeromq/ZeroMQExtension.scala
+++ b/akka-zeromq/src/main/scala/akka/zeromq/ZeroMQExtension.scala
@@ -68,7 +68,7 @@ class ZeroMQExtension(system: ActorSystem) extends Extension {
       case _                           ⇒ false
     }, "A socket type is required")
     val params = socketParameters.to[immutable.Seq]
-    Props(new ConcurrentSocketActor(params)).withDispatcher("akka.zeromq.socket-dispatcher")
+    Props(classOf[ConcurrentSocketActor], params).withDispatcher("akka.zeromq.socket-dispatcher")
   }
 
   /**