override socket select call to silence warnings

Author: Alessandro Chitolina

src/Connection/ConnectionManager.php

@@ -2,8 +2,8 @@
 
 namespace Fazland\Rabbitd\Connection;
 
+use Fazland\Rabbitd\PhpAmqpLib\Connection\AMQPSocketConnection;
 use PhpAmqpLib\Connection\AbstractConnection;
-use PhpAmqpLib\Connection\AMQPSocketConnection;
 
 class ConnectionManager
 {

src/PhpAmqpLib/Connection/AMQPSocketConnection.php

@@ -0,0 +1,49 @@
+<?php
+
+namespace Fazland\Rabbitd\PhpAmqpLib\Connection;
+
+use Fazland\Rabbitd\PhpAmqpLib\IO\SocketIO;
+use PhpAmqpLib\Connection\AbstractConnection;
+
+class AMQPSocketConnection extends AbstractConnection
+{
+    /**
+     * @param string $host
+     * @param int $port
+     * @param string $user
+     * @param string $password
+     * @param string $vhost
+     * @param bool $insist
+     * @param string $login_method
+     * @param null $login_response
+     * @param string $locale
+     * @param float $timeout
+     * @param bool $keepalive
+     */
+    public function __construct(
+        $host,
+        $port,
+        $user,
+        $password,
+        $vhost = '/',
+        $insist = false,
+        $login_method = 'AMQPLAIN',
+        $login_response = null,
+        $locale = 'en_US',
+        $timeout = 3,
+        $keepalive = false
+    ) {
+        $io = new SocketIO($host, $port, $timeout, $keepalive);
+
+        parent::__construct(
+            $user,
+            $password,
+            $vhost,
+            $insist,
+            $login_method,
+            $login_response,
+            $locale,
+            $io
+        );
+    }
+}

src/PhpAmqpLib/IO/SocketIO.php

@@ -0,0 +1,17 @@
+<?php
+
+namespace Fazland\Rabbitd\PhpAmqpLib\IO;
+
+use PhpAmqpLib\Wire\IO\SocketIO as BaseIO;
+
+class SocketIO extends BaseIO
+{
+    public function select($sec, $usec)
+    {
+        $read = array($this->getSocket());
+        $write = null;
+        $except = null;
+
+        return @socket_select($read, $write, $except, $sec, $usec);
+    }
+}