Always use persistent queues for AMQP/RabbitMQ transport

Author: darkin1

src/Queue.php

@@ -23,11 +23,6 @@ class Queue extends BaseQueue implements QueueContract
      */
     protected $psrContext;
 
-    /**
-     * @var boolean
-     */
-    protected $persistent = false;
-
     /**
      * @param PsrContext $psrContext
      * @param string     $queueName
@@ -53,8 +48,6 @@ 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);
     }
 
@@ -65,7 +58,7 @@ public function pushRaw($payload, $queue = null, array $options = [])
     {
         $message = $this->psrContext->createMessage($payload);
 
-        if ($this->persistent) {
+        if ($message instanceof \Interop\Amqp\Impl\AmqpMessage) {
             $message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
         }
 
@@ -82,7 +75,7 @@ public function later($delay, $job, $data = '', $queue = null)
     {
         $message = $this->psrContext->createMessage($this->createPayload($job, $data));
 
-        if (isset($job->persistent) && $job->persistent) {
+        if ($message instanceof \Interop\Amqp\Impl\AmqpMessage) {
             $message->setDeliveryMode(\Interop\Amqp\AmqpMessage::DELIVERY_MODE_PERSISTENT);
         }