diff --git a/modules/salesforce_push/src/PushQueue.php b/modules/salesforce_push/src/PushQueue.php index 7ef5382a42dd6ac36d4b619cc5f639c5d7bd01c5..a07021685b5dd672774d069ba497f027aed3bf13 100644 --- a/modules/salesforce_push/src/PushQueue.php +++ b/modules/salesforce_push/src/PushQueue.php @@ -15,7 +15,6 @@ use Drupal\Core\State\StateInterface; use Drupal\salesforce\EntityNotFoundException; use Drupal\salesforce\Event\SalesforceErrorEvent; use Drupal\salesforce\Event\SalesforceEvents; -use Drupal\salesforce\Event\SalesforceNoticeEvent; use Drupal\salesforce_mapping\Entity\SalesforceMappingInterface; use Symfony\Component\DependencyInjection\ContainerInterface; use Symfony\Component\EventDispatcher\EventDispatcherInterface; @@ -517,7 +516,7 @@ class PushQueue extends DatabaseQueue implements PushQueueInterface { '%id' => $item->entity_id, '%mapping' => $mapping->id(), ]; - $this->eventDispatcher->dispatch(new SalesforceNoticeEvent(NULL, $message, $args), SalesforceEvents::NOTICE); + $this->eventDispatcher->dispatch(new SalesforceErrorEvent(NULL, $message, $args), SalesforceEvents::ERROR); $this->deleteItem($item); return; } @@ -538,7 +537,7 @@ class PushQueue extends DatabaseQueue implements PushQueueInterface { '%item' => $item->item_id, '%fail' => $item->failures, ]; - $this->eventDispatcher->dispatch(new SalesforceNoticeEvent(NULL, $message, $args), SalesforceEvents::NOTICE); + $this->eventDispatcher->dispatch(new SalesforceErrorEvent(NULL, $message, $args), SalesforceEvents::ERROR); // Failed items will remain in queue, but not be released. They'll be // retried only when the current lease expires.