Taluu · February 9, 2016 16:53 · Feb 9, 2016
diff --git a/sleep.php b/sleep.php
@@ -0,0 +1,18 @@
+<?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;
+    }
+}