queue: add message expiration property

Author: hex7c0

src/Queue/RabbitMQQueue.php

@@ -78,6 +78,10 @@ public function pushRaw($payload, $queueName = null, array $options = [])
             $message->setContentType('application/json');
             $message->setDeliveryMode(AmqpMessage::DELIVERY_MODE_PERSISTENT);
 
+            if (isset($options['expiration'])) {
+                $message->setExpiration($options['expiration']);
+            }
+
             if (isset($options['headers'])) {
                 $message->setHeaders($options['headers']);
             }