Added support of plain handlers

Author: munir131

src/Jobs/PubSubJob.php

@@ -68,9 +68,34 @@ public function getJobId()
      */
     public function getRawBody()
     {
+        if ($this->pubsub->checkHandler($this->subscriber)) {
+            return $this->modifyPayload(
+                $this->job->data(),
+                $this->pubsub->getHandler($this->subscriber)
+            );
+        }
         return base64_decode($this->job->data());
     }
 
+    /**
+     * @param string|array $payload
+     * @param string $class
+     * @return array
+     */
+    private function modifyPayload($payload, $class)
+    {
+        if (!is_array($payload)) {
+            $payload = json_decode($payload, true);
+        }
+
+        $body = [
+            'job' => $class . '@handle',
+            'data' => $payload,
+        ];
+
+        return json_encode($body);
+    }
+
     /**
      * Delete the job from the queue.
      *

src/PubSubQueue.php

@@ -63,12 +63,39 @@ public function size($subscriber = null)
         return 0;
     }
 
+    /**
+     * Check whether handler exist
+     *
+     * @param  string  $queue
+     *
+     * @return bool
+     */
+    public function checkHandler($subscriber)
+    {
+        if (array_key_exists('plain_handlers', $this->config)) {
+            return array_key_exists($subscriber, $this->config['plain_handlers']);
+        }
+        return false;
+    }
+
+    /**
+     * Check whether handler exist
+     *
+     * @param  string  $queue
+     *
+     * @return string
+     */
+    public function getHandler($subscriber)
+    {
+        return $this->config['plain_handlers'][$subscriber];
+    }
+
     /**
      * Push a new job onto the queue.
      *
      * @param  string|object  $job
      * @param  mixed   $data
-     * @param  string  $queue
+     * @param  string  $subscriber
      *
      * @return mixed
      */
@@ -81,7 +108,7 @@ public function push($job, $data = '', $subscriber = null)
      * Push a raw payload onto the queue.
      *
      * @param  string  $payload
-     * @param  string  $queue
+     * @param  string  $subscriber
      * @param  array   $options
      *
      * @return array