1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
|
<?php
namespace Illuminate\Tests\Integration\Console;
use Illuminate\Bus\Queueable;
use Illuminate\Console\Scheduling\Schedule;
use Illuminate\Container\Container;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Support\Facades\Queue;
use Orchestra\Testbench\TestCase;
class JobSchedulingTest extends TestCase
{
public function testJobQueuingRespectsJobQueue()
{
Queue::fake();
/** @var Schedule $scheduler */
$scheduler = $this->app->make(Schedule::class);
// all job names were set to an empty string so that the registered shutdown function in CallbackEvent does nothing
// that function would in this test environment fire after everything was run, including the tearDown method
// (which flushes the entire container) which would then result in a ReflectionException when the container would try
// to resolve the config service (which is needed in order to resolve the cache store for the mutex that is being cleared)
$scheduler->job(JobWithDefaultQueue::class)->name('')->everyMinute();
$scheduler->job(JobWithDefaultQueueTwo::class, 'another-queue')->name('')->everyMinute();
$scheduler->job(JobWithoutDefaultQueue::class)->name('')->everyMinute();
$events = $scheduler->events();
foreach ($events as $event) {
$event->run($this->app);
}
Queue::assertPushedOn('test-queue', JobWithDefaultQueue::class);
Queue::assertPushedOn('another-queue', JobWithDefaultQueueTwo::class);
Queue::assertPushedOn(null, JobWithoutDefaultQueue::class);
$this->assertTrue(Queue::pushed(JobWithDefaultQueueTwo::class, function ($job, $pushedQueue) {
return $pushedQueue === 'test-queue-two';
})->isEmpty());
}
public function testJobQueuingRespectsJobConnection()
{
Queue::fake();
/** @var Schedule $scheduler */
$scheduler = $this->app->make(Schedule::class);
// all job names were set to an empty string so that the registered shutdown function in CallbackEvent does nothing
// that function would in this test environment fire after everything was run, including the tearDown method
// (which flushes the entire container) which would then result in a ReflectionException when the container would try
// to resolve the config service (which is needed in order to resolve the cache store for the mutex that is being cleared)
$scheduler->job(JobWithDefaultConnection::class)->name('')->everyMinute();
$scheduler->job(JobWithDefaultConnection::class, null, 'foo')->name('')->everyMinute();
$scheduler->job(JobWithoutDefaultConnection::class)->name('')->everyMinute();
$scheduler->job(JobWithoutDefaultConnection::class, null, 'bar')->name('')->everyMinute();
$events = $scheduler->events();
foreach ($events as $event) {
$event->run($this->app);
}
$this->assertSame(1, Queue::pushed(JobWithDefaultConnection::class, function (JobWithDefaultConnection $job, $pushedQueue) {
return $job->connection === 'test-connection';
})->count());
$this->assertSame(1, Queue::pushed(JobWithDefaultConnection::class, function (JobWithDefaultConnection $job, $pushedQueue) {
return $job->connection === 'foo';
})->count());
$this->assertSame(0, Queue::pushed(JobWithDefaultConnection::class, function (JobWithDefaultConnection $job, $pushedQueue) {
return $job->connection === null;
})->count());
$this->assertSame(1, Queue::pushed(JobWithoutDefaultConnection::class, function (JobWithoutDefaultConnection $job, $pushedQueue) {
return $job->connection === null;
})->count());
$this->assertSame(1, Queue::pushed(JobWithoutDefaultConnection::class, function (JobWithoutDefaultConnection $job, $pushedQueue) {
return $job->connection === 'bar';
})->count());
}
}
class JobWithDefaultQueue implements ShouldQueue
{
use Queueable, InteractsWithQueue;
public function __construct()
{
$this->onQueue('test-queue');
}
}
class JobWithDefaultQueueTwo implements ShouldQueue
{
use Queueable, InteractsWithQueue;
public function __construct()
{
$this->onQueue('test-queue-two');
}
}
class JobWithoutDefaultQueue implements ShouldQueue
{
use Queueable, InteractsWithQueue;
}
class JobWithDefaultConnection implements ShouldQueue
{
use Queueable, InteractsWithQueue;
public function __construct()
{
$this->onConnection('test-connection');
}
}
class JobWithoutDefaultConnection implements ShouldQueue
{
use Queueable, InteractsWithQueue;
}
|
