Added nap strategy otherweise the CPU is at 100%

config/module.config.php

@@ -46,8 +46,7 @@
          */
         'worker_strategies' => array(
             'default' => array(
-               // 'SlmQueueDoctrine\Strategy\IdleNapStrategy' => array('nap_duration' => 1),
-               // 'SlmQueueDoctrine\Strategy\ClearObjectManagerStrategy'
+               'SlmQueueQueue\Strategy\IdleNapStrategy' => array('nap_duration' => 1),
             ),
             'queues' => array(
             ),
@@ -57,9 +56,7 @@
          */
         'strategy_manager' => array(
             'invokables' => array(
-               // 'SlmQueueDoctrine\Strategy\IdleNapStrategy' => 'SlmQueueDoctrine\Strategy\IdleNapStrategy',
-               // 'SlmQueueDoctrine\Strategy\ClearObjectManagerStrategy'
-               //                                             => 'SlmQueueDoctrine\Strategy\ClearObjectManagerStrategy'
+                'SlmQueueRedis\Strategy\IdleNapStrategy' => 'SlmQueueRedis\Strategy\IdleNapStrategy',
             )
         ),
     )

src/SlmQueueRedis/Paginator/Adapter/RedisQueue.php

@@ -26,9 +26,10 @@ public function getItems($offset, $itemCountPerPage)
         $ids = $this->queue->getAdapter()->slice(
             $this->queue->getName(),
             $offset,
-            $itemCountPerPage
+            $offset + $itemCountPerPage
         );
 
+
         $jobs = array();
         foreach($ids as $id) {
             $jobs[$id] = $this->queue->peek($id);

src/SlmQueueRedis/Queue/RedisQueue.php

@@ -60,7 +60,6 @@ public function getAdapter() {
      */
     public function push(JobInterface $job, array $options = array())
     {
-
         $id = $this->adapter->push(
             $this->getName(),
             $this->serializeJob($job)
@@ -141,4 +140,60 @@ public function peek($id) {
     public function purge() {
         $this->getAdapter()->purge($this->getName());
     }
+
+
+//    /**
+//     * Create a job instance based on serialized input
+//     *
+//     * Instantiate a job based on a serialized data string. The string
+//     * is a JSON string containing job name, content and metadata. Use
+//     * the decoded JSON value to create a job instance, configure it
+//     * and return it.
+//     *
+//     * @param  string $string
+//     * @param  array  $metadata
+//     * @return \SlmQueue\Job\JobInterface
+//     */
+//    public function unserializeJob($string, array $metadata = array())
+//    {
+//        $data     =  $string; //json_decode($string, true);
+//        $name     =  $data['metadata']['__name__'];
+//        $metadata += $data['metadata'];
+//        $content  =  $data['content']; //unserialize($data['content']);
+//
+//        /** @var $job \SlmQueue\Job\JobInterface */
+//        $job = $this->getJobPluginManager()->get($name);
+//
+//        $job->setContent($content);
+//        $job->setMetadata($metadata);
+//
+//        if ($job instanceof QueueAwareInterface) {
+//            $job->setQueue($this);
+//        }
+//
+//        return $job;
+//    }
+//
+//    /**
+//     * Serialize job to allow persistence
+//     *
+//     * The serialization format is a JSON object with keys "content",
+//     * "metadata" and "__name__". When a job is fetched from the SL, a job name
+//     * will be set and be available as metadata. An invokable job has no service
+//     * name and therefore the FQCN will be used.
+//     *
+//     * @param  JobInterface $job The job to persist
+//     * @return string
+//     */
+//    public function serializeJob(JobInterface $job)
+//    {
+//        $job->setMetadata('__name__', $job->getMetadata('__name__', get_class($job)));
+//
+//        $data = array(
+//            'content'  => $job->getContent(),
+//            'metadata' => $job->getMetadata()
+//        );
+//
+//        return $data;
+//    }
 }

src/SlmQueueRedis/Strategy/IdleNapStrategy.php

@@ -0,0 +1,58 @@
+<?php
+
+namespace SlmQueueRedisStrategy;
+
+use SlmQueue\Strategy\AbstractStrategy;
+use SlmQueue\Worker\WorkerEvent;
+use SlmQueueDoctrine\Queue\DoctrineQueueInterface;
+use Zend\EventManager\EventManagerInterface;
+
+class IdleNapStrategy extends AbstractStrategy
+{
+    /**
+     * How long should we sleep when the worker is idle before trying again
+     *
+     * @var int
+     */
+    protected $napDuration = 1;
+
+    /**
+     * @param int $napDuration
+     */
+    public function setNapDuration($napDuration)
+    {
+        $this->napDuration = (int) $napDuration;
+    }
+
+    /**
+     * @return int
+     */
+    public function getNapDuration()
+    {
+        return $this->napDuration;
+    }
+
+    /**
+     * {@inheritDoc}
+     */
+    public function attach(EventManagerInterface $events)
+    {
+        $this->listeners[] = $events->attach(
+            WorkerEvent::EVENT_PROCESS_IDLE,
+            array($this, 'onIdle'),
+            1
+        );
+    }
+
+    /**
+     * @param WorkerEvent $event
+     */
+    public function onIdle(WorkerEvent $event)
+    {
+        $queue = $event->getQueue();
+
+        if ($queue instanceof DoctrineQueueInterface) {
+            sleep($this->napDuration);
+        }
+    }
+}