Merge pull request #49 from carcabot/master

Priority, Delay , TTR Job

Author: miccheng

demo/queues/BeanstalkSampleQueue.php

@@ -19,10 +19,10 @@ public function __construct()
                         );
     }
 
-    public function addJob($newJob = null)
+    public function addJob($newJob = null, $DEFAULT_PRIORITY=1024, $DEFAULT_DELAY=0, $DEFAULT_TTR=60)
     {
         $formatted_data = array('worker'=>$this->queueWorker, 'data'=>$newJob);
-        $this->dataSource->add($formatted_data);
+        $this->dataSource->add($formatted_data, $DEFAULT_PRIORITY, $DEFAULT_DELAY, $DEFAULT_TTR);
 
         return true;
     }

src/PHPQueue/Backend/Beanstalkd.php

@@ -34,20 +34,20 @@ public function connect()
      * @param  array   $data
      * @return boolean Status of saving
      */
-    public function add($data=array())
+    public function add($data=array(), $DEFAULT_PRIORITY=1024, $DEFAULT_DELAY=0, $DEFAULT_TTR=60)
     {
-        $this->push($data);
+        $this->push($data, $DEFAULT_PRIORITY, $DEFAULT_DELAY, $DEFAULT_TTR);
         return true;
     }
 
     /**
      * @param array $data
      * @return integer Primary ID of the new record.
      */
-    public function push($data)
+    public function push($data, $DEFAULT_PRIORITY=1024, $DEFAULT_DELAY=0, $DEFAULT_TTR=60)
     {
         $this->beforeAdd();
-        $response = $this->getConnection()->useTube($this->tube)->put(json_encode($data));
+        $response = $this->getConnection()->useTube($this->tube)->put(json_encode($data), $DEFAULT_PRIORITY, $DEFAULT_DELAY, $DEFAULT_TTR);
         if (!$response) {
             throw new BackendException("Unable to save job.");
         }