Merge pull request vyuldashev#125 from werewolf81/master

Fix for lost connections with RabbitMQ

Author: vyuldashev

src/VladimirYuldashev/LaravelQueueRabbitMQ/Queue/RabbitMQQueue.php

@@ -324,10 +324,17 @@ public function getCorrelationId()
     /**
      * @param string    $action
      * @param Exception $e
+     * @throws Exception
      */
     protected function reportConnectionError($action, Exception $e)
     {
         Log::error('AMQP error while attempting '.$action.': '.$e->getMessage());
+
+        // If it's set to false, throw an error rather than waiting
+        if ($this->sleepOnError === false) {
+            throw new \RuntimeException('Error writing data to the connection with RabbitMQ');
+        }
+
         // Sleep so that we don't flood the log file
         sleep($this->sleepOnError);
     }

src/config/rabbitmq.php

@@ -40,6 +40,8 @@
         'auto_delete' => env('RABBITMQ_EXCHANGE_AUTODELETE', false),
     ],
 
-    'sleep_on_error' => env('RABBITMQ_ERROR_SLEEP', 5), // the number of seconds to sleep if there's an error communicating with rabbitmq
+    // 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),
 
 ];