protected function dispatch($queueEvent)
    {
        $event = urldecode($queueEvent->data);
        $event = unserialize($event);

        if ($event) {
            $this->dispatcher->dispatch($event::NAME, $event);

            if ($event->getHasError()) {
                $this->setError($queueEvent->id);
                $this->response($event::NAME, $event->getError(), 'ERROR', $event->getParam());
            } else {
                $this->response($event::NAME, $event->getReturnMessages(), 'NOTICE', $event->getParam());
            }

            return $event;
        }
    }
protected function dispatch($queueEvent)
    {
        $event = urldecode($queueEvent->data);
        $event = unserialize($event);

        if ($event) {
            $this->dispatcher->dispatch($event::NAME, $event);

            if ($event->getHasError()) {
                $this->setError($queueEvent->id);
                $this->response($event::NAME, $event->getError(), 'ERROR', $event->getParam());
            } else {
                $this->response($event::NAME, $event->getReturnMessages(), 'NOTICE', $event->getParam());
            }

            return $event;
        }
    }
protected function dispatch ( $ queueEvent ) { $ event = urldecode ( $ queueEvent -> data ) ; $ event = unserialize ( $ event ) ; if ( $ event ) { $ this -> dispatcher -> dispatch ( $ event :: NAME , $ event ) ; if ( $ event -> getHasError ( ) ) { $ this -> setError ( $ queueEvent -> id ) ; $ this -> response ( $ event :: NAME , $ event -> getError ( ) , 'ERROR' , $ event -> getParam ( ) ) ; } else { $ this -> response ( $ event :: NAME , $ event -> getReturnMessages ( ) , 'NOTICE' , $ event -> getParam ( ) ) ; } return $ event ; } }
Ruft die Verarbeitung eines Events der Queue auf.
@param $queueEvent
@return array
Ruft die Verarbeitung eines Events der Queue auf .