Skip to content

Commit 2e23742

Browse files
committed
change available_time value based on current time with delay
1 parent e17b54e commit 2e23742

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

src/PubSubQueue.php

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -146,7 +146,7 @@ public function later($delay, $job, $data = '', $subscriber = null)
146146
return $this->pushRaw(
147147
$this->createPayload($job, $data),
148148
$subscriber,
149-
['available_at' => (string) $this->availableAt($delay)]
149+
['available_at' => (string) time() + $delay]
150150
);
151151
}
152152

@@ -243,8 +243,11 @@ public function acknowledgeAndPublish(Message $message, $subscriberName = null,
243243

244244
$subscription->acknowledge($message);
245245

246+
// $options = array_merge([
247+
// 'available_at' => (string) $this->availableAt($delay),
248+
// ], $options);
246249
$options = array_merge([
247-
'available_at' => (string) $this->availableAt($delay),
250+
'available_at' => (string) time() + $delay,
248251
], $options);
249252

250253
return $topic->publish([
@@ -265,7 +268,7 @@ public function republish(Message $message, $queue = null, $options = [], $delay
265268
$topic = $this->getTopic($this->getQueue($queue));
266269

267270
$options = array_merge([
268-
'available_at' => (string) $this->availableAt($delay),
271+
'available_at' => (string) time() + $delay,
269272
], $options);
270273

271274
return $topic->publish([

0 commit comments

Comments
 (0)