Skip to content

Commit c54b6fa

Browse files
authored
implement queue release delay
1 parent 6742995 commit c54b6fa

File tree

1 file changed

+4
-4
lines changed

1 file changed

+4
-4
lines changed

src/Job.php

+4-4
Original file line numberDiff line numberDiff line change
@@ -62,14 +62,14 @@ public function delete()
6262
*/
6363
public function release($delay = 0)
6464
{
65-
if ($delay) {
66-
throw new \LogicException('To be implemented');
67-
}
65+
parent::release($job);
6866

6967
$requeueMessage = clone $this->psrMessage;
7068
$requeueMessage->setProperty('x-attempts', $this->attempts() + 1);
7169

72-
$this->psrContext->createProducer()->send($this->psrConsumer->getQueue(), $requeueMessage);
70+
$this->psrContext->createProducer()
71+
->setDeliveryDelay($this->secondsUntil($delay))
72+
->send($this->psrConsumer->getQueue(), $requeueMessage);
7373

7474
$this->psrConsumer->acknowledge($this->psrMessage);
7575
}

0 commit comments

Comments
 (0)