File tree Expand file tree Collapse file tree 1 file changed +3
-1
lines changed
src/FintechFab/LaravelQueueRabbitMQ/Queue Expand file tree Collapse file tree 1 file changed +3
-1
lines changed Original file line number Diff line number Diff line change 66use AMQPException ;
77use AMQPExchange ;
88use AMQPQueue ;
9+ use DateTime ;
910use FintechFab \LaravelQueueRabbitMQ \Queue \Jobs \RabbitMQJob ;
1011use Illuminate \Contracts \Queue \Queue as QueueContract ;
1112use Illuminate \Queue \Queue ;
@@ -208,13 +209,14 @@ private function declareQueue($name)
208209 /**
209210 * @param string $destination
210211 *
211- * @param int $delay
212+ * @param DateTime| int $delay
212213 *
213214 * @return AMQPQueue
214215 */
215216 private function declareDelayedQueue ($ destination , $ delay )
216217 {
217218 $ destination = $ this ->getQueueName ($ destination );
219+ $ delay = $ this ->getSeconds ($ delay );
218220 $ name = $ destination . '_deferred_ ' . $ delay ;
219221
220222 $ queue = new AMQPQueue ($ this ->channel );
You can’t perform that action at this time.
0 commit comments