Add myjobs example

Author: yidas

README.md

@@ -159,7 +159,7 @@ class My_worker extends \yidas\queue\worker\Controller
 // ...
 ```
 
-> As above, `myjobs` library is defined by your own application which handles your job processes.
+> As above, `myjobs` library is defined by your own application which handles your job processes. [Example code of myjobs with Redis](https://github.com/yidas/codeigniter-queue-worker/blob/master/examples/myjobs/MyjobsWithRedis.php)
 
 #### 2. Build Worker
 

examples/myjobs/MyjobsWithDatabase.php

@@ -0,0 +1,42 @@
+<?php
+
+/**
+ * myjobs sample code using database for single worker
+ * 
+ * This sample library uses database table records as a queue, we delete `exist()` and `popJob()` 
+ * methods and add a `getJob()` to implement the database characteristics for single worker usage.
+ * 
+ * @author  Nick Tsai <[email protected]>
+ */
+class MyjobsWithDatabase
+{
+    function __construct() 
+    {
+        $this->CI = & get_instance();
+        $this->CI->load->model("job_queue_model");
+    }
+
+    /**
+     * Get a undo job from database table
+     *
+     * @return array
+     */
+    public function getJob()
+    {
+        return $this->CI->job_queue_model->getJob();
+    }
+
+    /**
+     * Process then delete a job
+     *
+     * @param array $job
+     * @return boolean
+     */
+    public function processJob($job)
+    {
+        // Your own job process here
+
+        // Delete job record after finishing process
+        return $this->CI->job_queue_model->deleteJob($job['id']);
+    }
+}

examples/myjobs/MyjobsWithRedis.php

@@ -0,0 +1,82 @@
+<?php
+
+/**
+ * myjobs sample code using Redis
+ * 
+ * This sample library mixed Redis client connection, which you can separate into components in
+ * actual development.
+ * 
+ * @author  Nick Tsai <[email protected]>
+ * @package https://github.com/nrk/predis
+ */
+class MyjobsWithRedis
+{
+    /**
+     * Redis key
+     */
+    const QUEUE_KEY = 'your-job-key';
+    
+    /**
+     * Redis client
+     *
+     * @var Predis\Client
+     */
+    protected $redisClient;
+    
+    function __construct() 
+    {
+        // You can store Redis config into application config, for example: `$this->CI->config->item('redis', 'services');`
+        $this->redisClient = new Predis\Client(['host'=>'yourHostOrIP', 'scheme'=>'tcp', 'port'=>6379], ['parameters'=>['password'=>'yourpass']]);
+
+        // Connection check
+        try {
+
+            $this->redisClient->type('test');
+
+        } catch (Predis\Connection\ConnectionException $e) {
+
+            if (ENVIRONMENT=='development') {
+                throw $e;
+            }
+            // Prevent further error
+            exit;
+        }
+    }
+
+    /**
+     * Check if there are any jobs from Redis queue
+     *
+     * @return boolean
+     */
+    public function exists()
+    {
+        return $this->redisClient->exists(self::QUEUE_KEY);
+    }
+
+    /**
+     * Pop up a job from Redis queue
+     *
+     * @return array
+     */
+    public function popJob()
+    {
+        // Assume storing JSON string data in queue
+        // Using LPOP or RPOP depends on your producer push
+        $taskJSON = $this->redisClient->lpop(self::QUEUE_KEY);
+
+        return json_decode($taskJSON, true);
+    }
+
+    /**
+     * Process a job
+     *
+     * @param array $job
+     * @return boolean
+     */
+    public function processJob($job)
+    {
+        // Your own job process here
+
+        return true;
+    }
+}