Merge pull request vyuldashev#612 from Triplkrypl/master

load timeouts from laravel config

Author: khepin

README.md

@@ -529,6 +529,33 @@ Available protocols : `tcp`, `ssl`, `tls`
 ],
 ```
 
+### Network Timeouts
+
+For network timeouts configuration you can use option parameters.
+All float values are in seconds and zero value can mean infinite timeout.
+Example contains default values.
+
+```php
+'connections' => [
+    // ...
+
+    'rabbitmq' => [
+        // ...
+
+        'options' => [
+            // ...
+
+            'connection_timeout' => 3.0,
+            'read_timeout' => 3.0,
+            'write_timeout' => 3.0,
+            'channel_rpc_timeout' => 0.0,
+        ],
+    ],
+
+    // ...
+],
+```
+
 ### Octane support
 
 Starting with 13.3.0, this package supports [Laravel Octane](https://laravel.com/docs/octane) out of the box.

src/Queue/Connection/ConfigFactory.php

@@ -38,6 +38,7 @@ public static function make(array $config = []): AMQPConnectionConfig
             self::getHostFromConfig($connectionConfig, $config);
             self::getHeartbeatFromConfig($connectionConfig, $config);
             self::getNetworkProtocolFromConfig($connectionConfig, $config);
+            self::getTimeoutsFromConfig($connectionConfig, $config);
         });
     }
 
@@ -99,4 +100,27 @@ protected static function getNetworkProtocolFromConfig(AMQPConnectionConfig $con
             $connectionConfig->setNetworkProtocol($networkProtocol);
         }
     }
+
+    protected static function getTimeoutsFromConfig(AMQPConnectionConfig $connectionConfig, array $config): void
+    {
+        $connectionTimeout = Arr::get($config, self::CONFIG_OPTIONS.'.connection_timeout');
+        if (is_numeric($connectionTimeout) && floatval($connectionTimeout) >= 0) {
+            $connectionConfig->setConnectionTimeout((float) $connectionTimeout);
+        }
+
+        $readTimeout = Arr::get($config, self::CONFIG_OPTIONS.'.read_timeout');
+        if (is_numeric($readTimeout) && floatval($readTimeout) >= 0) {
+            $connectionConfig->setReadTimeout((float) $readTimeout);
+        }
+
+        $writeTimeout = Arr::get($config, self::CONFIG_OPTIONS.'.write_timeout');
+        if (is_numeric($writeTimeout) && floatval($writeTimeout) >= 0) {
+            $connectionConfig->setWriteTimeout((float) $writeTimeout);
+        }
+
+        $chanelRpcTimeout = Arr::get($config, self::CONFIG_OPTIONS.'.channel_rpc_timeout');
+        if (is_numeric($chanelRpcTimeout) && floatval($chanelRpcTimeout) >= 0) {
+            $connectionConfig->setChannelRPCTimeout((float) $chanelRpcTimeout);
+        }
+    }
 }