1515use Psr \Container \ContainerInterface ;
1616use Symfony \Component \EventDispatcher \EventDispatcher ;
1717use Symfony \Component \Messenger \Envelope ;
18+ use Symfony \Component \Messenger \Event \WorkerMessageHandledEvent ;
1819use Symfony \Component \Messenger \Event \WorkerMessageReceivedEvent ;
20+ use Symfony \Component \Scheduler \Event \PostRunEvent ;
1921use Symfony \Component \Scheduler \Event \PreRunEvent ;
2022use Symfony \Component \Scheduler \EventListener \DispatchSchedulerEventListener ;
2123use Symfony \Component \Scheduler \Generator \MessageContext ;
@@ -33,20 +35,22 @@ public function testDispatchSchedulerEvents()
3335
3436 $ schedulerProvider = new SomeScheduleProvider ([$ defaultRecurringMessage ]);
3537 $ scheduleProviderLocator = $ this ->createMock (ContainerInterface::class);
36- $ scheduleProviderLocator ->expects ($ this ->once ())->method ('has ' )->willReturn (true );
37- $ scheduleProviderLocator ->expects ($ this ->once ())->method ('get ' )->willReturn ($ schedulerProvider );
38+ $ scheduleProviderLocator ->expects ($ this ->any ())->method ('has ' )->willReturn (true );
39+ $ scheduleProviderLocator ->expects ($ this ->any ())->method ('get ' )->willReturn ($ schedulerProvider );
3840
3941 $ context = new MessageContext ('default ' , 'default ' , $ trigger , $ this ->createMock (\DateTimeImmutable::class));
4042 $ envelope = (new Envelope (new \stdClass ()))->with (new ScheduledStamp ($ context ));
4143
4244 /** @var ContainerInterface $scheduleProviderLocator */
4345 $ listener = new DispatchSchedulerEventListener ($ scheduleProviderLocator , $ eventDispatcher = new EventDispatcher ());
4446 $ workerReceivedEvent = new WorkerMessageReceivedEvent ($ envelope , 'default ' );
47+ $ workerHandledEvent = new WorkerMessageHandledEvent ($ envelope , 'default ' );
4548 $ secondListener = new TestEventListener ();
4649
4750 $ eventDispatcher ->addListener (PreRunEvent::class, [$ secondListener , 'preRun ' ]);
48- $ eventDispatcher ->addListener (PreRunEvent ::class, [$ secondListener , 'postRun ' ]);
51+ $ eventDispatcher ->addListener (PostRunEvent ::class, [$ secondListener , 'postRun ' ]);
4952 $ listener ->onMessageReceived ($ workerReceivedEvent );
53+ $ listener ->onMessageHandled ($ workerHandledEvent );
5054
5155 $ this ->assertTrue ($ secondListener ->preInvoked );
5256 $ this ->assertTrue ($ secondListener ->postInvoked );
0 commit comments