public function process(Message $message, Context $context)
    {
        $container = $this->kernel->getContainer();

        $data = \json_decode($message->getBody());

        $eventName = $this->prefix . $data->uri;
        $payload = $data->path;

        $dispatcher = $container->get('event_dispatcher');
        $dispatcher->dispatch($eventName, new BusEvent($payload));

        return self::ACK;
    }
public function process(Message $message, Context $context)
    {
        $container = $this->kernel->getContainer();

        $data = \json_decode($message->getBody());

        $eventName = $this->prefix . $data->uri;
        $payload = $data->path;

        $dispatcher = $container->get('event_dispatcher');
        $dispatcher->dispatch($eventName, new BusEvent($payload));

        return self::ACK;
    }
public function process ( Message $ message , Context $ context ) { $ container = $ this -> kernel -> getContainer ( ) ; $ data = \ json_decode ( $ message -> getBody ( ) ) ; $ eventName = $ this -> prefix . $ data -> uri ; $ payload = $ data -> path ; $ dispatcher = $ container -> get ( 'event_dispatcher' ) ; $ dispatcher -> dispatch ( $ eventName , new BusEvent ( $ payload ) ) ; return self :: ACK ; }
Emit bus multicast messages to symfony kernel instance

@param Message $message
@param Context $context
@return \Symfony\Component\HttpFoundation\Response
Emit bus multicast messages to symfony kernel instance