heartbeat

Author: lexxksb

src/Protocols/Amqp.php

@@ -272,16 +272,21 @@ protected function connect(): bool
 
             [$host, $port] = explode(':', $host);
 
+            $heartbeat = $this->settings['heartbeat'] ?? null;
+            
             $credentials = [
                 'host'            => $host,
                 'port'            => $port,
                 'vhost'           => $this->settings['vhost'],
                 'login'           => $this->login,
                 'password'        => $this->password,
                 'connect_timeout' => $this->settings['connect_timeout'] ?? 0,
-                'heartbeat'       => $this->settings['heartbeat'] ?? 0,
             ];
 
+            if ($heartbeat !== null) {
+                $credentials['heartbeat'] = $heartbeat;
+            }
+            
             $link = new AMQPConnection($credentials);
 
             try {