Skip to content

Commit d70a6c7

Browse files
committed
[5.x] Fix RedisQueue::later() never passing the delay to the payload
1 parent cbb4d2e commit d70a6c7

2 files changed

Lines changed: 13 additions & 1 deletion

File tree

src/RedisQueue.php

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -113,7 +113,7 @@ protected function createPayloadArray($job, $queue, $data = '')
113113
#[\Override]
114114
public function later($delay, $job, $data = '', $queue = null)
115115
{
116-
$args = version_compare(Application::class, '12.11.0', '>=')
116+
$args = version_compare(Application::VERSION, '12.11.0', '>=')
117117
? [$job, $queue, $data, $delay]
118118
: [$job, $queue, $data];
119119

tests/Feature/QueueProcessingTest.php

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -3,6 +3,7 @@
33
namespace Laravel\Horizon\Tests\Feature;
44

55
use Carbon\CarbonImmutable;
6+
use Illuminate\Foundation\Application;
67
use Illuminate\Support\Facades\Event;
78
use Illuminate\Support\Facades\Queue;
89
use Illuminate\Support\Facades\Redis;
@@ -41,6 +42,17 @@ public function test_pending_delayed_jobs_are_stored_in_pending_job_database()
4142
$this->assertSame('pending', Redis::connection('horizon')->hget($id, 'status'));
4243
}
4344

45+
public function test_pending_delayed_jobs_are_stored_with_their_delay()
46+
{
47+
if (version_compare(Application::VERSION, '12.11.0', '<')) {
48+
$this->markTestSkipped('Requires Laravel 12.11 or newer.');
49+
}
50+
51+
$id = Queue::later(60, new Jobs\BasicJob);
52+
$payload = json_decode(Redis::connection('horizon')->hget($id, 'payload'), true);
53+
$this->assertSame(60, $payload['delay']);
54+
}
55+
4456
public function test_pending_jobs_are_stored_with_their_tags()
4557
{
4658
$id = Queue::push(new Jobs\BasicJob);

0 commit comments

Comments
 (0)