Wie pausieren Sie eine Laravel-Warteschlange

Question

Ich habe eine Warteschlange, die Anforderungen an einen Remote-Dienst sendet. Manchmal wird dieser Service gewartet. Ich möchte, dass alle Warteschlangentasks in 10 Minuten pausieren und erneut versuchen, wenn eine solche Situation auftritt. Wie implementiere ich das?

Answer 1

<?php 

namespace App\Jobs; 

use ... 

class SendRequest implements ShouldQueue 
{ 
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels; 

    const REMOTE_SERVER_UNAVAILABLE = 'remote_server_unavailable'; 

    private $msg; 
    private $retryAfter; 

    public function __construct($msg) 
    { 
     $this->msg = $msg; 
     $this->retryAfter = 10; 
    } 

    /** 
    * Execute the job. 
    * 
    * @return void 
    */ 
    public function handle(){ 
     try { 
      // if we have tried sending the request and get a RemoteServerException, we will 
      // redispatch the job directly and return. 
      if(Cache::get(self::REMOTE_SERVER_UNAVAILABLE)) { 
       self::dispatch($this->msg)->delay(Carbon::now()->addMinutes($this->retryAfter)); 
       return;     
      } 
      // send request to remote server 
      // ... 
     } catch (RemoteServerException $e) { 
      // set a cache value expires in 10 mins if not exists. 
      Cache::add(self::REMOTE_SERVER_UNAVAILABLE,'1', $this->retryAfter); 
      // if the remote service undergoes a maintenance, redispatch a new delayed job. 
      self::dispatch($this->msg)->delay(Carbon::now()->addMinutes($this->retryAfter));    
     } 
    } 
}