- support of heartbeat and timeouts

Author: martianoff

composer.json

@@ -8,9 +8,9 @@
     "php-amqplib/php-amqplib": "2.6.*"
   },
   "require-dev": {
-    "laravel/framework": ">=4.0.0",
+    "laravel/framework": ">=5.3.0",
     "squizlabs/php_codesniffer": "1.*",
-    "orchestra/testbench": "3.0.4",
+    "orchestra/testbench": "3.3.*",
     "phpunit/phpunit": "4.3.*"
   },
   "autoload": {

src/Connectors/AmqpConnector.php

@@ -4,7 +4,7 @@
 
 use Forumhouse\LaravelAmqp\Queue\AMQPQueue;
 use Illuminate\Queue\Connectors\ConnectorInterface;
-use PhpAmqpLib\Connection\AMQPConnection;
+use PhpAmqpLib\Connection\AMQPStreamConnection;
 
 /**
  * Class AmqpConnector
@@ -22,12 +22,21 @@ class AmqpConnector implements ConnectorInterface
      */
     public function connect(array $config)
     {
-        $connection = new AMQPConnection(
+        $connection = new AMQPStreamConnection(
             $config['host'],
             $config['port'],
             $config['user'],
             $config['password'],
-            isset($config['vhost']) ? $config['vhost'] : '/'
+            isset($config['vhost']) ? $config['vhost'] : '/',
+            false,
+            'AMQPLAIN',
+            null,
+            'en_US',
+            isset($config['connection_timeout']) ? $config['connection_timeout'] : 3,
+            isset($config['read_write_timeout']) ? $config['read_write_timeout'] : 3,
+            null,
+            isset($config['keepalive']) ? $config['keepalive'] : false,
+            isset($config['heartbeat']) ? $config['heartbeat'] : 0
         );
 
         if (!isset($config['exchange_type'])) {

src/Queue/AMQPQueue.php

@@ -9,6 +9,7 @@
 use Illuminate\Queue\Queue;
 use PhpAmqpLib\Channel\AMQPChannel;
 use PhpAmqpLib\Connection\AMQPConnection;
+use PhpAmqpLib\Connection\AMQPStreamConnection;
 use PhpAmqpLib\Message\AMQPMessage;
 use PhpAmqpLib\Wire\AMQPTable;
 
@@ -61,7 +62,7 @@ class AMQPQueue extends Queue implements QueueContract
     private $messageProperties;
 
     /**
-     * @param AMQPConnection $connection
+     * @param AMQPStreamConnection $connection
      * @param string         $defaultQueueName  Default queue name
      * @param array          $queueFlags        Queue flags See a list of parameters to
      *                                          \PhpAmqpLib\Channel\AMQPChannel::queue_declare. Parameters should be
@@ -74,7 +75,7 @@ class AMQPQueue extends Queue implements QueueContract
      * @param mixed          $exchangeFlags     Exchange flags
      */
     public function __construct(
-        AMQPConnection $connection,
+        AMQPStreamConnection $connection,
         $defaultQueueName = null,
         $queueFlags = [],
         $messageProperties = [],