amqp delay message with dlx strategy.

Author: makasim

src/AmqpConnector.php

@@ -2,6 +2,8 @@
 
 namespace Enqueue\LaravelQueue;
 
+use Enqueue\AmqpTools\DelayStrategyAware;
+use Enqueue\AmqpTools\RabbitMqDlxDelayStrategy;
 use Interop\Amqp\AmqpContext;
 
 class AmqpConnector extends Connector
@@ -10,11 +12,15 @@ public function connect(array $config)
     {
         $queue = parent::connect($config);
 
-        if (false == $queue->getPsrContext() instanceof AmqpContext) {
-            throw new \LogicException(sprintf('The context must be instance of "%s" but got "%s"', AmqpContext::class, get_class($queue->getPsrContext()));
+        /** @var AmqpContext $amqpContext */
+        $amqpContext = $queue->getPsrContext();
+        if (false == $amqpContext instanceof AmqpContext) {
+            throw new \LogicException(sprintf('The context must be instance of "%s" but got "%s"', AmqpContext::class, get_class($queue->getPsrContext())));
         }
 
-        // TODO set delay strategy.
+        if ($amqpContext instanceof DelayStrategyAware) {
+            $amqpContext->setDelayStrategy(new RabbitMqDlxDelayStrategy());
+        }
 
         return $queue;
     }