diff --git a/src/queue/connector/Sync.php b/src/queue/connector/Sync.php index 3f4d420..3f55f6c 100644 --- a/src/queue/connector/Sync.php +++ b/src/queue/connector/Sync.php @@ -32,14 +32,14 @@ public function push($job, $data = '', $queue = null) $queueJob = $this->resolveJob($this->createPayload($job, $data), $queue); try { - $this->triggerEvent(new JobProcessing($this->connection, $job)); + $this->triggerEvent(new JobProcessing($this->connection, $queueJob)); $queueJob->fire(); - $this->triggerEvent(new JobProcessed($this->connection, $job)); + $this->triggerEvent(new JobProcessed($this->connection, $queueJob)); } catch (Exception | Throwable $e) { - $this->triggerEvent(new JobFailed($this->connection, $job, $e)); + $this->triggerEvent(new JobFailed($this->connection, $queueJob, $e)); throw $e; }