@@ -46,7 +46,7 @@ public function testDispatchSchedulerEvents()
46
46
$ listener = new DispatchSchedulerEventListener ($ scheduleProviderLocator , $ eventDispatcher = new EventDispatcher ());
47
47
$ workerReceivedEvent = new WorkerMessageReceivedEvent ($ envelope , 'default ' );
48
48
$ workerHandledEvent = new WorkerMessageHandledEvent ($ envelope ->with (new HandledStamp ('result ' , 'handlerName ' )), 'default ' );
49
- $ workerFailedEvent = new WorkerMessageFailedEvent ($ envelope , 'default ' , new \Exception ());
49
+ $ workerFailedEvent = new WorkerMessageFailedEvent ($ envelope , 'default ' , new \Exception (' failed ' ));
50
50
$ secondListener = new TestEventListener ();
51
51
52
52
$ eventDispatcher ->addListener (PreRunEvent::class, [$ secondListener , 'preRun ' ]);
@@ -57,10 +57,10 @@ public function testDispatchSchedulerEvents()
57
57
$ listener ->onMessageFailed ($ workerFailedEvent );
58
58
59
59
$ this ->assertInstanceOf (PreRunEvent::class, $ secondListener ->preRunEvent );
60
- $ this ->assertEquals ('result ' , $ secondListener ->postRunEvent ->getResult ());
60
+ $ this ->assertSame ('result ' , $ secondListener ->postRunEvent ->getResult ());
61
61
$ this ->assertInstanceOf (PostRunEvent::class, $ secondListener ->postRunEvent );
62
62
$ this ->assertInstanceOf (FailureEvent::class, $ secondListener ->failureEvent );
63
- $ this ->assertEquals (new \Exception (), $ secondListener ->failureEvent ->getError ());
63
+ $ this ->assertEquals (new \Exception (' failed ' ), $ secondListener ->failureEvent ->getError ());
64
64
}
65
65
}
66
66
0 commit comments