removeSubscriberFromQueueLink = $removeSubscriberFromQueueLink; } /** * Removes subscriber from queue * * @param Subscriber $subject * @param Subscriber $subscriber * @return Subscriber * @SuppressWarnings(PHPMD.UnusedFormalParameter) */ public function afterUnsubscribe(Subscriber $subject, Subscriber $subscriber): Subscriber { if ($subscriber->isStatusChanged() && $subscriber->getSubscriberStatus() === Subscriber::STATUS_UNSUBSCRIBED) { $this->removeSubscriberFromQueueLink->execute((int) $subscriber->getId()); } return $subscriber; } }