make zmq streaming compatible with akka