code: public function onConsume(ItemPipelineEvent $event)
      {
          if ($event->getItemSkip()) {
              $this->skip($event);
          } else {
              $this->consume($event);
          }
      }
docs: Entry point of consume event.
  
  @param ItemPipelineEvent $event