Drupal: Queue Worker

offering_sync_sendgrid.services.yml

services:
  logger.channel.sync_sendgrid:
    parent: logger.channel_base
    arguments: [ 'sync_sendgrid' ]

SyncSendgridQueueWorker.php

<?php

namespace Drupal\offering_sync_sendgrid\Plugin\QueueWorker;

use Drupal\Core\Logger\LoggerChannelInterface;
use Drupal\Core\Plugin\ContainerFactoryPluginInterface;
use Drupal\Core\Queue\QueueWorkerBase;
use Drupal\offering_sync_sendgrid\OfferingSyncSendgridService;
use Symfony\Component\DependencyInjection\ContainerInterface;

/**
 * @QueueWorker(
 *   id = "sync_sendgrid",
 *   title = @Translation("Sync sendgrid worker"),
 *   cron = {"time" = 60}
 * )
 */
class SyncSendgridQueueWorker extends QueueWorkerBase implements ContainerFactoryPluginInterface
{

  /**
   * Logging channel.
   *
   * @var \Drupal\Core\Logger\LoggerChannelInterface
   */
  protected $logger;

  /**
   * {@inheritDoc}
   */
  public function __construct(array $configuration, $plugin_id, $plugin_definition, LoggerChannelInterface $logger)
  {
    parent::__construct($configuration, $plugin_id, $plugin_definition);
    $this->logger = $logger;
  }

  /**
   * {@inheritDoc}
   */
  public static function create(ContainerInterface $container, array $configuration, $plugin_id, $plugin_definition)
  {
    return new static(
      $configuration,
      $plugin_id,
      $plugin_definition,
      $container->get('logger.factory')->get('logger.channel.sync_sendgrid'),
    );
  }

  /**
   * {@inheritDoc}
   */
  public function processItem($data)
  {
    $service = \Drupal::service('offering_sync_sendgrid.sync_sendgrid');
    $email = $data['email'];
    $response = $data['subscription_newsletter'] ? $service->addContactsToSendgrid([$email]) : $service->removeContactsfromList([$email]);

    if ($response) {
      $action = $data['subscription_newsletter'] ? 'added to' : 'removed from';
      $loggerMessage = sprintf('user @email %s the Sendgrid List at @timestamp', $action);
      $this->logger->notice(
        $loggerMessage,
        [
          '@email' => $email,
          '@timestamp' => $data['timestamp']
        ]
      );
    }
  }
}