diff --git a/src/Worker.php b/src/Worker.php index 577a50f..727faca 100644 --- a/src/Worker.php +++ b/src/Worker.php @@ -31,6 +31,9 @@ public function runOnce(): bool { if ($this->queue->count() > 0) { $message = $this->queue->pop(); + + $task = json_decode($message, true)['task']; + $this->output(sprintf('[%s] Processing: %s', (new \DateTime)->format(\DateTime::RFC3339_EXTENDED), $task)); \call_user_func($this->handler, $message);