2017-09-16 6 views
0

Je suis prêt à envoyer un courriel à la liste d'adresses e-mail en utilisant queue. Sans utiliser la file d'attente mon code fonctionne bien mais avec la file d'attente il est montrant erreur suivant:Sérialisation de 'Fermeture' n'est pas autorisé dans Laravel 5.3 Courrier électronique

Exception in Queue.php line 86: Serialization of 'Closure' is not allowed 

    in /home/hizbul/Development/Projects/Laravel/fastskool/vendor/laravel/framework/src/Illuminate/Queue/Queue.php line 86 
    at serialize(object(SendMessageToStudent)) in Queue.php line 86 
    at Queue->createPayload(object(SendMessageToStudent), '') in DatabaseQueue.php line 81 
    at DatabaseQueue->push(object(SendMessageToStudent)) in Dispatcher.php line 184 
    at Dispatcher->pushCommandToQueue(object(DatabaseQueue), object(SendMessageToStudent)) in Dispatcher.php line 159 
    at Dispatcher->dispatchToQueue(object(SendMessageToStudent)) in Dispatcher.php line 73 
    at Dispatcher->dispatch(object(SendMessageToStudent)) in DispatchesJobs.php line 17 
    at Controller->dispatch(object(SendMessageToStudent)) in MessageController.php line 49 
    at MessageController->store(object(Request)) 
    at call_user_func_array(array(object(MessageController), 'store'), array(object(Request))) in Controller.php line 55 
    at Controller->callAction('store', array(object(Request))) in ControllerDispatcher.php line 44 
    at ControllerDispatcher->dispatch(object(Route), object(MessageController), 'store') in Route.php line 189 
    at Route->runController() in Route.php line 144 
    at Route->run(object(Request)) in Router.php line 653 
    at Router->Illuminate\Routing\{closure}(object(Request)) in Pipeline.php line 53 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in StaffAndAdmin.php line 40 
    at StaffAndAdmin->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in ModuleManager.php line 29 
    at ModuleManager->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in SwitchDatabaseConnection.php line 36 
    at SwitchDatabaseConnection->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in SubstituteBindings.php line 41 
    at SubstituteBindings->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in VerifyCsrfToken.php line 65 
    at VerifyCsrfToken->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in ShareErrorsFromSession.php line 49 
    at ShareErrorsFromSession->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in StartSession.php line 64 
    at StartSession->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in AddQueuedCookiesToResponse.php line 37 
    at AddQueuedCookiesToResponse->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in EncryptCookies.php line 59 
    at EncryptCookies->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in Pipeline.php line 104 
    at Pipeline->then(object(Closure)) in Router.php line 655 
    at Router->runRouteWithinStack(object(Route), object(Request)) in Router.php line 629 
    at Router->dispatchToRoute(object(Request)) in Router.php line 607 
    at Router->dispatch(object(Request)) in Kernel.php line 268 
    at Kernel->Illuminate\Foundation\Http\{closure}(object(Request)) in Pipeline.php line 53 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in Debugbar.php line 51 
    at Debugbar->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in CheckForMaintenanceMode.php line 46 
    at CheckForMaintenanceMode->handle(object(Request), object(Closure)) in Pipeline.php line 137 
    at Pipeline->Illuminate\Pipeline\{closure}(object(Request)) in Pipeline.php line 33 
    at Pipeline->Illuminate\Routing\{closure}(object(Request)) in Pipeline.php line 104 
    at Pipeline->then(object(Closure)) in Kernel.php line 150 
    at Kernel->sendRequestThroughRouter(object(Request)) in Kernel.php line 117 
    at Kernel->handle(object(Request)) in index.php line 68 

J'utilise database en tant que conducteur de file d'attente.

Après mon code de gestionnaire de file d'attente de travail:

class SendMessageToStudent implements ShouldQueue 
{ 
    use InteractsWithQueue, Queueable, SerializesModels; 

    private $data; 

    /** 
    * Create a new job instance. 
    * 
    * @param Request $request 
    */ 
    public function __construct(Request $request) 
    { 
     $this->data = $request; 
    } 

    /** 
    * Execute the job. 
    * 
    * @return void 
    */ 
    public function handle() 
    { 
     $student = $this->data; 
     $arrStudent = (new Message())->getEmailAddressList($student); 
     Mail::to($arrStudent)->send(new MessageSent($student)); 
    } 
} 

et le code répartiteur:

$this->dispatch(new SendMessageToStudent($request)); 

J'attends une solution réalisable.

Répondre

1

Vous ne pouvez pas sérialiser une demande. Seul un modèle éloquent peut être sérialisé et non sérialisé. Voir ici: https://laravel.com/docs/5.2/queues#writing-job-classes

Vous devez utiliser $ request-> all() au lieu de $ request. Puisque la demande est traitée comme une fermeture.

0

Essayez de supprimer cette ligne du constructeur:

$this->message = new Message(); 

et, dans la poignée directement initialisez elle.

$student = $this->data; 
$arrStudent = (new Message())->getEmailAddressList($student); 
Mail::to($arrStudent)->send(new MessageSent($student)); 
+0

C'est juste un refactor de code que la solution. – hizbul25

+0

@ hizbul25 J'ai fait face à une semaine de solution similaire, cela a fonctionné pour moi de cette façon. –