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;
    }
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}
{