Sync with cnages in queue interop.

Author: makasim

RedisProducer.php

@@ -2,6 +2,7 @@
 
 namespace Enqueue\Redis;
 
+use Interop\Queue\CompletionListener;
 use Interop\Queue\InvalidDestinationException;
 use Interop\Queue\InvalidMessageException;
 use Interop\Queue\PsrDestination;
@@ -10,6 +11,16 @@
 
 class RedisProducer implements PsrProducer
 {
+    /**
+     * @var CompletionListener
+     */
+    private $completionListener;
+
+    /**
+     * @var float
+     */
+    private $deliveryDelay = PsrMessage::DEFAULT_DELIVERY_DELAY;
+
     /**
      * @var Redis
      */
@@ -36,4 +47,36 @@ public function send(PsrDestination $destination, PsrMessage $message)
 
         $this->redis->lpush($destination->getName(), json_encode($message));
     }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function setCompletionListener(CompletionListener $listener = null)
+    {
+        $this->completionListener = $listener;
+    }
+
+    /**
+     * @return CompletionListener|null
+     */
+    public function getCompletionListener()
+    {
+        return $this->completionListener;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function getDeliveryDelay()
+    {
+        return $this->deliveryDelay;
+    }
+
+    /**
+     * {@inheritdoc}
+     */
+    public function setDeliveryDelay($deliveryDelay)
+    {
+        $this->deliveryDelay = $deliveryDelay;
+    }
 }