Merge pull request #252 from vasilevrv/master

Add linger param to zmq pusher

Author: Prophet777

DependencyInjection/Configuration.php

@@ -193,6 +193,9 @@ protected function addZmqNode()
                     ->defaultValue('tcp')
                     ->values(['tcp', 'ipc', 'inproc', 'pgm', 'epgm'])
                 ->end()
+                ->integerNode('linger')
+                    ->defaultValue(-1)
+                ->end()
             ->end();
 
         return $node;

Pusher/Zmq/ZmqPusher.php

@@ -25,6 +25,7 @@ protected function doPush($data, array $context)
 
             $context = new \ZMQContext(1, $config['persistent']);
             $this->connection = new \ZMQSocket($context, \ZMQ::SOCKET_PUSH);
+            $this->connection->setSockOpt(\ZMQ::SOCKOPT_LINGER, $config['linger']);
             $this->connection->connect($config['protocol'] . '://' . $config['host'] . ':' . $config['port']);
             $this->setConnected();
         }