LoggerSubscriber.php

<?php
namespace Quartz\Bridge;

use Psr\Log\LoggerInterface;
use Quartz\Events\ErrorEvent;
use Quartz\Events\Event;
use Quartz\Events\JobExecutionContextEvent;
use Symfony\Component\EventDispatcher\EventSubscriberInterface;

class LoggerSubscriber implements EventSubscriberInterface
{
    /**
     * @var LoggerInterface
     */
    private $logger;

    /**
     * @param LoggerInterface $logger
     */
    public function __construct(LoggerInterface $logger)
    {
        $this->logger = $logger;
    }

    public function schedulerStarting()
    {
        $this->debug('Scheduler starting');
    }

    public function schedulerStarted()
    {
        $this->debug('Scheduler started');
    }

    public function schedulerShuttingdown()
    {
        $this->debug('Scheduler shutting down');
    }

    public function schedulerShutdown()
    {
        $this->debug('Scheduler shutdown');
    }

    public function jobToBeExecuted(JobExecutionContextEvent $event)
    {
        $this->debug(sprintf('Job to be executed: "%s"', (string) $event->getContext()->getJobDetail()->getKey()));
    }

    public function jobWasExecuted(JobExecutionContextEvent $event)
    {
        $this->debug(sprintf('Job was executed: "%s"', (string) $event->getContext()->getJobDetail()->getKey()));

        if ($e = $event->getContext()->getException()) {
            $this->debug(sprintf('Job has thrown exception: "%s", "%s"', get_class($e), $e->getMessage()));
        }
    }

    public function jobExecutionVetoed(JobExecutionContextEvent $event)
    {
        $this->debug(sprintf('Job was vetoed: "%s"', (string) $event->getContext()->getJobDetail()->getKey()));
    }

    public function triggerComplete(JobExecutionContextEvent $event)
    {
        $trigger = $event->getContext()->getTrigger();

        $previousFireTime = $trigger->getPreviousFireTime() ? $trigger->getPreviousFireTime()->format(DATE_ISO8601) : 'null';
        $scheduledFireTime = $trigger->getScheduledFireTime() ? $trigger->getScheduledFireTime()->format(DATE_ISO8601) : 'null';
        $nextFireTime = $trigger->getNextFireTime() ? $trigger->getNextFireTime()->format(DATE_ISO8601) : 'null';

        $this->debug(sprintf('Trigger execution completed: PreviousFireTime: "%s" ScheduledFireTime: "%s" NextFireTime: "%s"',
            $previousFireTime, $scheduledFireTime, $nextFireTime));
    }

    public function schedulerError(ErrorEvent $event)
    {
        $this->debug('Error: '.$event->getMessage());

        if ($event->getException()) {
            $this->debug($event->getException()->getMessage());
        }
    }

    /**
     * {@inheritdoc}
     */
    public static function getSubscribedEvents()
    {
        return [
            Event::SCHEDULER_STARTING => 'schedulerStarting',
            Event::SCHEDULER_STARTED => 'schedulerStarted',
            Event::SCHEDULER_SHUTTINGDOWN => 'schedulerShuttingdown',
            Event::SCHEDULER_SHUTDOWN => 'schedulerShutdown',
            Event::SCHEDULER_ERROR => 'schedulerError',
            Event::JOB_TO_BE_EXECUTED => 'jobToBeExecuted',
            Event::JOB_WAS_EXECUTED => 'jobWasExecuted',
            Event::JOB_EXECUTION_VETOED => 'jobExecutionVetoed',
            Event::TRIGGER_COMPLETE => 'triggerComplete',
        ];
    }

    private function debug($message)
    {
        $this->logger->debug(sprintf('[%s] %s', date('H:i:s'), $message));
    }
}