I struggling from last 3 days about how I can read queued job payload in Laravel.
What I’ve achieved till yet. Dispatch a job and see that it is available on AWS SQS queue. After that I’ve executed listener and worker for AWS to process queued jobs and I see that it is working fine as well.
Right now I am stuck on how I can read QUEUED job payload / messagebody / attributes from AWS SQS.
Here is my code example if possible than anyone from this whole community please help me.
<?php
namespace AppJobs;
use AppCookieXrayConsentLog;
use AppCookieXrayScript;
use CarbonCarbon;
use IlluminateBusQueueable;
use IlluminateQueueSerializesModels;
use IlluminateQueueInteractsWithQueue;
use IlluminateContractsQueueShouldQueue;
use IlluminateFoundationBusDispatchable;
use IlluminateSupportFacadesDB;
use IlluminateSupportFacadesLog;
use IlluminateSupportFacadesQueue;
use IlluminateSupportFacadesStorage;
class QueueCookieConsent implements ShouldQueue
{
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
protected $job;
// The maximum attempts of this job
public $tries = 5;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct(array $data)
{
$this->job = $data;
$this->onConnection('sqs');
$this->onQueue('dev_consent');
}
/**
* Execute the job.
*
* @return void
*/
public function handle()
{
// Tried by these ways
Log::info('job => ' .' This --- '. json_encode(Queue::pop()->payload()));
Log::info('job => ' .' This --- '. json_encode($this->job));
}
}
Logs are printed if I remove this json_encode() from log info as mentioned above.
Advertisement
Answer
In your case you want to access $this->job->payload()
, but you are overwriting the job variable in the constructor, with this line.
$this->job = $data;
Instead rename this to something else.
$this->data = $data;
Now you can access the payload like so.
$this->job->payload()