public function onMessageEnd(Message $message)
    {
        $worker = $this->getWorkerForStream($message->getResource());
        $worker->getJobInfo()->end = microtime(true);
        $this->eventEmitter->emit('peridot.concurrency.worker.completed', [$worker]);
    }
public function onMessageEnd(Message $message)
    {
        $worker = $this->getWorkerForStream($message->getResource());
        $worker->getJobInfo()->end = microtime(true);
        $this->eventEmitter->emit('peridot.concurrency.worker.completed', [$worker]);
    }
public function onMessageEnd ( Message $ message ) { $ worker = $ this -> getWorkerForStream ( $ message -> getResource ( ) ) ; $ worker -> getJobInfo ( ) -> end = microtime ( true ) ; $ this -> eventEmitter -> emit ( 'peridot.concurrency.worker.completed' , [ $ worker ] ) ; }
Match a running worker to a message resource and
emit a completed event for that worker.

@param Message $message
Match a running worker to a message resource and emit a completed event for that worker .