Merge pull request #261 from SimonHeimberg/zmq-fixes

ZmqPusher works with other protocols than tcp

Author: Prophet777

Pusher/Zmq/ZmqServerPushHandler.php

@@ -78,7 +78,7 @@ public function handle(LoopInterface $loop, WampServerInterface $app)
             $config['port']
         ));
 
-        $this->consumer->bind('tcp://' . $config['host'] . ':' . $config['port']);
+        $this->consumer->bind($config['protocol'] . '://' . $config['host'] . ':' . $config['port']);
 
         $this->consumer->on('message', function ($data) use ($app, $config) {
 
@@ -91,7 +91,7 @@ public function handle(LoopInterface $loop, WampServerInterface $app)
                 $this->eventDispatcher->dispatch(Events::PUSHER_SUCCESS, new PushHandlerEvent($data, $this));
             } catch (\Exception $e) {
                 $this->logger->error(
-                    'AMQP handler failed to ack message', [
+                    'zmq handler failed to ack message', [
                         'exception_message' => $e->getMessage(),
                         'file' => $e->getFile(),
                         'line' => $e->getLine(),