Skip to content

Commit 5e2fe1b

Browse files
author
Stephen Odoardi
committed
fix(2228): added test for queue deleteAndRelease Method
1 parent 41de0c7 commit 5e2fe1b

File tree

1 file changed

+19
-1
lines changed

1 file changed

+19
-1
lines changed

tests/QueueTest.php

+19-1
Original file line numberDiff line numberDiff line change
@@ -104,7 +104,7 @@ public function testIncrementAttempts(): void
104104
$this->assertEquals(0, $others_jobs[0]['attempts']);
105105
}
106106

107-
public function testReleaseJob(): void
107+
public function testJobRelease(): void
108108
{
109109
$job_id = Queue::push('test', ['action' => 'QueueJobExpired'], 'test');
110110
$this->assertNotNull($job_id);
@@ -118,5 +118,23 @@ public function testReleaseJob(): void
118118

119119
$this->assertCount(1, $jobs);
120120
$this->assertEquals(1, $jobs[0]['attempts']);
121+
$this->assertNotEquals($job_id, $jobs[0]['_id']);
122+
}
123+
124+
public function testQueueDeleteAndRelease(): void
125+
{
126+
$queue = 'test';
127+
$job_id = Queue::push($queue, ['action' => 'QueueJobExpired'], 'test');
128+
129+
$job = Queue::pop('test');
130+
Queue::deleteAndRelease($queue, $job, 0);
131+
132+
$jobs = Queue::getDatabase()
133+
->table(Config::get('queue.connections.database.table'))
134+
->get();
135+
136+
$this->assertCount(1, $jobs);
137+
$this->assertEquals(1, $jobs[0]['attempts']);
138+
$this->assertNotEquals($job_id, $jobs[0]['_id']);
121139
}
122140
}

0 commit comments

Comments
 (0)