sleep.php

<?php
// snippet
class Processor
{
      public function sleep(array $options)
    {
        if (null === $options['timeout']) {
            return $this->processor instanceof SleepyInterface ? $this->processor->sleep($options) : true;
        }

        if ((time() - $options['reference']) <= $options['timeout']) {
            return $this->processor instanceof SleepyInterface ? $this->processor->sleep($options) : true;
        }

        $this->logger->info('The process took too long. Killing the consumer...');
        return false;
    }
}