Core/Consumers/AbstractConsumer.php
protected function dispatchConsumerTimingEvent($intervalMs, MessageInterface $message)
    {
        $event = new TimingEvent(TimingEvent::CONSUMER_TIMING);
        $event->setIntervalMs($intervalMs);
        $event->setMessage($message);

        if (null !== ($dispatcher = $this->getEventDispatcher())) {
            $dispatcher->dispatch(TimingEvent::CONSUMER_TIMING, $event);
        }
    }
protected function dispatchConsumerTimingEvent($intervalMs, MessageInterface $message)
    {
        $event = new TimingEvent(TimingEvent::CONSUMER_TIMING);
        $event->setIntervalMs($intervalMs);
        $event->setMessage($message);

        if (null !== ($dispatcher = $this->getEventDispatcher())) {
            $dispatcher->dispatch(TimingEvent::CONSUMER_TIMING, $event);
        }
    }
protected function dispatchConsumerTimingEvent ( $ intervalMs , MessageInterface $ message ) { $ event = new TimingEvent ( TimingEvent :: CONSUMER_TIMING ) ; $ event -> setIntervalMs ( $ intervalMs ) ; $ event -> setMessage ( $ message ) ; if ( null !== ( $ dispatcher = $ this -> getEventDispatcher ( ) ) ) { $ dispatcher -> dispatch ( TimingEvent :: CONSUMER_TIMING , $ event ) ; } }
This function dispatchs a timing event with the amount of time it took to consume a message.

@param $intervalMs int the timing interval that we would like to emanate
@param MessageInterface $message

@return mixed
This function dispatchs a timing event with the amount of time it took to consume a message .