src/Service/RetryClientFactory.php line 27

Open in your IDE?
  1. <?php
  2. namespace App\Service;
  4. use GuzzleHttp\HandlerStack;
  5. use GuzzleHttp\Handler\CurlHandler;
  6. use GuzzleHttp\Middleware;
  7. use GuzzleHttp\Psr7\Request;
  8. use GuzzleHttp\Psr7\Response;
  9. use GuzzleHttp\Exception\RequestException;
  10. use GuzzleHttp\Exception\ConnectException;
  11. use GuzzleHttp\Client;
  12. use GuzzleHttp\Exception\GuzzleException;
  14. class RetryClientFactory
  15. {
  17. public static function buildClient($cfg)
  18. {
  19. $handlerStack = HandlerStack::create(new CurlHandler());
  20. $handlerStack->push(Middleware::retry('App\Service\RetryClientFactory::decider', 'App\Service\RetryClientFactory::delay'));
  22. $cfg['handler'] = $handlerStack;
  24. return new Client($cfg);
  25. }
  27. public static function decider($retries, Request $request, Response $response = null, GuzzleException $exception = null)
  28. {
  29. // Limit the number of retries to 5
  30. if ($retries >= 5) {
  31. return false;
  32. }
  34. // Retry connection exceptions
  35. if ($exception instanceof ConnectException) {
  36. return true;
  37. }
  39. if ($response) {
  40. // Retry on server errors
  41. if ($response->getStatusCode() >= 500) {
  42. return true;
  43. }
  44. }
  46. return false;
  47. }
  49. public static function delay($numberOfRetries)
  50. {
  51. return 1000 * $numberOfRetries;
  52. }
  53. }