EventListener/SyncExecuteConsumeEventListener.php
protected function setItem(ItemPipelineEvent $event)
    {
        if (!parent::setItem($event)) {
            return false;
        }

        /** @var SyncExecuteItem $item */
        $item = $this->getItem();
        if (!$item instanceof SyncExecuteItem) {
            return false;
        }

        $tempSyncStorageData = $item->getSyncStorageData();

        if (!isset($tempSyncStorageData['type'])) {
            $this->log(
                sprintf('No operation type defined for document id: %s', $item->getDocument()->getId()),
                LogLevel::ERROR
            );

            return false;
        }
        $this->setSyncStorageData($tempSyncStorageData);

        return true;
    }
protected function setItem(ItemPipelineEvent $event)
    {
        if (!parent::setItem($event)) {
            return false;
        }

        /** @var SyncExecuteItem $item */
        $item = $this->getItem();
        if (!$item instanceof SyncExecuteItem) {
            return false;
        }

        $tempSyncStorageData = $item->getSyncStorageData();

        if (!isset($tempSyncStorageData['type'])) {
            $this->log(
                sprintf('No operation type defined for document id: %s', $item->getDocument()->getId()),
                LogLevel::ERROR
            );

            return false;
        }
        $this->setSyncStorageData($tempSyncStorageData);

        return true;
    }
{@inheritdoc}