diff --git a/src/Queue/Connection/ConfigFactory.php b/src/Queue/Connection/ConfigFactory.php index 7783b9cd..e1340556 100644 --- a/src/Queue/Connection/ConfigFactory.php +++ b/src/Queue/Connection/ConfigFactory.php @@ -31,6 +31,13 @@ public static function make(array $config = []): AMQPConnectionConfig true) ); + // Set the keepalive from config + $connectionConfig->setKeepalive(in_array( + Arr::get($config, 'keepalive'), + [true, 1, '1', 'true', 'yes'], + true) + ); + if ($connectionConfig->isSecure()) { self::getSLLOptionsFromConfig($connectionConfig, $config); }