Add persisten functionality

Author: darkin1

README.md

@@ -7,6 +7,7 @@ It also supports extended AMQP features such as queue declaration and message de
 
 The package allows you to use queue interop transport the [laravel way](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/laravel/queues.md) as well as integrates the [enqueue simple client](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/laravel/quick_tour.md#enqueue-simple-client). 
 
+To make message [persistent](https://www.rabbitmq.com/persistence-conf.html) add to Laravel Job class field `protected $persistent = true;`
 ## Resources
 
 * [Documentation](https://github.com/php-enqueue/enqueue-dev/blob/master/docs/index.md)

src/Queue.php

@@ -23,6 +23,11 @@ class Queue extends BaseQueue implements QueueContract
      */
     protected $psrContext;
 
+    /**
+     * @var boolean
+     */
+    protected $persistent = false;
+
     /**
      * @param PsrContext $psrContext
      * @param string     $queueName
@@ -48,6 +53,8 @@ public function size($queue = null)
      */
     public function push($job, $data = '', $queue = null)
     {
+        $this->persistent = $job->persistent ?? false;
+
         return $this->pushRaw($this->createPayload($job, $data), $queue);
     }
 
@@ -56,9 +63,15 @@ public function push($job, $data = '', $queue = null)
      */
     public function pushRaw($payload, $queue = null, array $options = [])
     {
+        $message = $this->psrContext->createMessage($payload);
+
+        if ($this->persistent) {
+            $message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
+        }
+
         return $this->psrContext->createProducer()->send(
             $this->getQueue($queue),
-            $this->psrContext->createMessage($payload)
+            $message
         );
     }
 
@@ -69,11 +82,13 @@ public function later($delay, $job, $data = '', $queue = null)
     {
         $message = $this->psrContext->createMessage($this->createPayload($job, $data));
 
+        if (isset($job->persistent) && $job->persistent) {
+            $message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
+        }
+
         return $this->psrContext->createProducer()
             ->setDeliveryDelay($this->secondsUntil($delay) * 1000)
-
-            ->send($this->getQueue($queue), $message)
-        ;
+            ->send($this->getQueue($queue), $message);
     }
 
     /**