FEATURE: Allow configuration of RabbitMq heartbeat

Classes/Queue/RabbitQueue.php

@@ -70,8 +70,24 @@ public function __construct(string $name, array $options = [])
         $vhost = $clientOptions['vhost'] ?? '/';
         $insist = isset($clientOptions['insist']) ? (bool) $clientOptions['insist'] : false;
         $loginMethod = isset($clientOptions['loginMethod']) ? (string) $clientOptions['loginMethod'] : 'AMQPLAIN';
-
-        $this->connection = new AMQPStreamConnection($host, $port, $username, $password, $vhost, $insist, $loginMethod, null, 'en_US', 3.0, 3.0, null, true, 0);
+        $heartbeat = (int) ($clientOptions['heartbeat'] ?? 0);
+
+        $this->connection = new AMQPStreamConnection(
+            $host,
+            $port,
+            $username,
+            $password,
+            $vhost,
+            $insist,
+            $loginMethod,
+            null,
+            'en_US',
+            3.0,
+            3.0,
+            null,
+            true,
+            $heartbeat
+        );
         $this->channel = $this->connection->channel();
 
         // a worker should only get one message at a time

README.md

@@ -115,6 +115,7 @@ Flowpack:
               port: 5672
               username: guest
               password: guest
+              heartbeat: 60 # Sets RabbitMQ connection heartbeat to 60 seconds
 
       queues:
         producer-import: