|
2 | 2 |
|
3 | 3 | namespace Bref\Symfony\Messenger\Service\Sqs;
|
4 | 4 |
|
| 5 | +use Throwable; |
5 | 6 | use Bref\Context\Context;
|
6 | 7 | use Bref\Event\Sqs\SqsEvent;
|
7 | 8 | use Bref\Event\Sqs\SqsHandler;
|
@@ -39,10 +40,10 @@ public function __construct(
|
39 | 40 | BusDriver $busDriver,
|
40 | 41 | MessageBusInterface $bus,
|
41 | 42 | SerializerInterface $serializer,
|
42 |
| - string $transportName = null, |
43 |
| - LoggerInterface $logger = null, |
| 43 | + ?string $transportName = null, |
| 44 | + ?LoggerInterface $logger = null, |
44 | 45 | bool $partialBatchFailure = false,
|
45 |
| - SqsTransportNameResolver $transportNameResolver = null |
| 46 | + ?SqsTransportNameResolver $transportNameResolver = null |
46 | 47 | ) {
|
47 | 48 | $this->busDriver = $busDriver;
|
48 | 49 | $this->bus = $bus;
|
@@ -102,7 +103,7 @@ public function handleSqs(SqsEvent $event, Context $context): void
|
102 | 103 | } catch (UnrecoverableExceptionInterface $exception) {
|
103 | 104 | $this->logger->error(sprintf('SQS record with id "%s" failed to be processed. But failure was marked as unrecoverable. Message will be acknowledged.', $record->getMessageId()));
|
104 | 105 | $this->logger->error($exception);
|
105 |
| - } catch (\Throwable $exception) { |
| 106 | + } catch (Throwable $exception) { |
106 | 107 | if ($this->partialBatchFailure === false) {
|
107 | 108 | throw $exception;
|
108 | 109 | }
|
|
0 commit comments