use heartbeat and timeouts

Author: Devon Weller

config/rabbitmq.php

@@ -79,7 +79,7 @@
      * Determine the number of seconds to sleep if there's an error communicating with rabbitmq
      * If set to false, it'll throw an exception rather than doing the sleep for X seconds.
      */
-    'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5),
+    'sleep_on_error' => false,
 
     /*
      * Optional SSL params if an SSL connection is used
@@ -104,4 +104,13 @@
          */
         'timeout' => env('RABBITMQ_RECEIVE_TIMEOUT', 5000),
     ],
+
+    /**
+     * default to an 8 second heartbeat
+     */
+    'timeouts' => [
+        'read' => 16,
+        'write' => 16,
+        'heartbeat' => 8,
+    ]
 ];

src/Queue/Connectors/RabbitMQConnector.php

@@ -58,6 +58,9 @@ public function connect(array $config): Queue
             'ssl_key' => $config['ssl_params']['local_key'],
             'ssl_passphrase' => $config['ssl_params']['passphrase'],
             'receive_method' => isset($config['receive']) ? $config['receive']['method'] : 'basic_get',
+            'heartbeat' => isset($config['timeouts']) ? $config['timeouts']['heartbeat'] : 0,
+            'read_timeout' => isset($config['timeouts']) ? $config['timeouts']['read'] : 3,
+            'write_timeout' => isset($config['timeouts']) ? $config['timeouts']['write'] : 3,
         ]);
 
         if ($factory instanceof DelayStrategyAware) {