public function onMessageEnd(Message $message)
    {
        $worker = $this->getWorkerForStream($message->getResource());
        $worker->getJobInfo()->end = microtime(true);
        $this->eventEmitter->emit('peridot.concurrency.worker.completed', [$worker]);
    }