Skip to content

Commit bf47c42

Browse files
committed
feature/easy-serverless-dispatch-additional-events
- Add WorkerMessageHandledEvent and WorkerMessageFailedEvent
1 parent f86224c commit bf47c42

1 file changed

Lines changed: 6 additions & 6 deletions

File tree

packages/EasyServerless/bundle/SqsHandler/SqsHandler.php

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -186,6 +186,12 @@ private function dispatchWorkerMessageFailedEvent(Envelope $envelope, Throwable
186186
$this->eventDispatcher?->dispatch($failedEvent);
187187
}
188188

189+
private function dispatchWorkerMessageHandledEvent(Envelope $envelope): void
190+
{
191+
$handledEvent = new WorkerMessageHandledEvent($envelope, $this->transportName);
192+
$this->eventDispatcher?->dispatch($handledEvent);
193+
}
194+
189195
/**
190196
* @throws \Psr\Container\ContainerExceptionInterface
191197
* @throws \Psr\Container\NotFoundExceptionInterface
@@ -201,12 +207,6 @@ private function getRetryStrategyForTransport(string $alias): ?RetryStrategyInte
201207
return null;
202208
}
203209

204-
private function dispatchWorkerMessageHandledEvent(Envelope $envelope): void
205-
{
206-
$handledEvent = new WorkerMessageHandledEvent($envelope, $this->transportName);
207-
$this->eventDispatcher?->dispatch($handledEvent);
208-
}
209-
210210
private function isThrowableExplicitlyUnRecoverable(Throwable $throwable): bool
211211
{
212212
if ($throwable instanceof RecoverableExceptionInterface) {

0 commit comments

Comments
 (0)