importerFactory = $importerFactory; $this->customer = $customer; $this->helper = $data; } /** * @param \Magento\Framework\Event\Observer $observer */ public function execute(\Magento\Framework\Event\Observer $observer) { try { /** @var \Magento\Wishlist\Model\Wishlist $wishlist */ $wishlist = $observer->getEvent()->getDataObject(); $customer = $this->customer->getById($wishlist->getCustomerId()); $isEnabled = $this->helper->isEnabled($customer->getWebsiteId()); $syncEnabled = $this->helper->getWebsiteConfig( \Dotdigitalgroup\Email\Helper\Config::XML_PATH_CONNECTOR_SYNC_WISHLIST_ENABLED, $customer->getWebsiteId() ); //create a queue item to remote single wishlist if ($isEnabled && $syncEnabled && $wishlist->getId()) { //register in queue with importer $this->importerFactory->create()->registerQueue( \Dotdigitalgroup\Email\Model\Importer::IMPORT_TYPE_WISHLIST, [$wishlist->getId()], \Dotdigitalgroup\Email\Model\Importer::MODE_SINGLE_DELETE, $customer->getWebsiteId() ); } } catch (\Exception $e) { $this->helper->debug((string)$e, []); } } }