|
12 | 12 | namespace Symfony\Bundle\FrameworkBundle\Tests\Functional;
|
13 | 13 |
|
14 | 14 | use Symfony\Bundle\FrameworkBundle\Tests\Fixtures\Messenger\BarMessage;
|
| 15 | +use Symfony\Bundle\FrameworkBundle\Tests\Fixtures\Messenger\DummyCommand; |
15 | 16 | use Symfony\Bundle\FrameworkBundle\Tests\Fixtures\Messenger\DummySchedule;
|
16 | 17 | use Symfony\Bundle\FrameworkBundle\Tests\Fixtures\Messenger\DummyTask;
|
17 | 18 | use Symfony\Bundle\FrameworkBundle\Tests\Fixtures\Messenger\FooMessage;
|
@@ -88,6 +89,29 @@ public function testAutoconfiguredScheduler()
|
88 | 89 | $this->assertSame([['5', 6], ['7', 8]], $calls['attributesOnMethod']);
|
89 | 90 | }
|
90 | 91 |
|
| 92 | + public function testAutoconfiguredSchedulerCommand() |
| 93 | + { |
| 94 | + $container = self::getContainer(); |
| 95 | + $container->set('clock', $clock = new MockClock('2023-10-26T08:59:59Z')); |
| 96 | + |
| 97 | + $this->assertTrue($container->get('receivers')->has('scheduler_dummy_command')); |
| 98 | + $this->assertInstanceOf(SchedulerTransport::class, $cron = $container->get('receivers')->get('scheduler_dummy_command')); |
| 99 | + $bus = $container->get(MessageBusInterface::class); |
| 100 | + |
| 101 | + $getCalls = static function (float $sleep) use ($clock, $cron, $bus) { |
| 102 | + DummyCommand::$calls = []; |
| 103 | + $clock->sleep($sleep); |
| 104 | + foreach ($cron->get() as $message) { |
| 105 | + $bus->dispatch($message->with(new ReceivedStamp('scheduler_dummy_command'))); |
| 106 | + } |
| 107 | + |
| 108 | + return DummyCommand::$calls; |
| 109 | + }; |
| 110 | + |
| 111 | + $this->assertSame([], $getCalls(0)); |
| 112 | + $this->assertSame(['execute' => [0 => null, 1 => 'test']], $getCalls(1)); |
| 113 | + } |
| 114 | + |
91 | 115 | public function testSchedulerWithCustomTransport()
|
92 | 116 | {
|
93 | 117 | $container = self::getContainer();
|
|
0 commit comments