Skip to content

Commit 5c9fdb5

Browse files
committed
feature #32454 [Messenger] Add SQS transport (jderusse)
This PR was merged into the 5.1-dev branch. Discussion ---------- [Messenger] Add SQS transport | Q | A | ------------- | --- | Branch? | master | Bug fix? | no | New feature? | yes | BC breaks? | no | Deprecations? | no | Tests pass? | yes | Fixed tickets | N/A | License | MIT | Doc PR | TODO This PR add the AWS SQS transport in messenger. It also add a `DisconnectedReceiverInterface` that allows the worker to release not-proceeded message (which are not automatically released in SQS and have to wait a TTL). Tell me if you prefer to move it in a dedicated PR. accepted DNS: - `sqs://default/accountId/queueName` - `sqs://default/queueName` - `sqs://default/queueName?region=us-east-2` - `sqs://my_custome_endpoint:12345/queueName?sslmode=disabled` To reduce AWS costs, the implementation performs a long polling call and prefetch several messages. TO get ~real time worker, one could use `./bin/console messenger:consume --sleep 0.001` Commits ------- c226479d5f [Messenger] Add SQS transport
2 parents 79b2246 + ccfdafd commit 5c9fdb5

File tree

1 file changed

+4
-0
lines changed

1 file changed

+4
-0
lines changed

Resources/config/messenger.xml

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -85,6 +85,10 @@
8585
<tag name="kernel.reset" method="reset" />
8686
</service>
8787

88+
<service id="messenger.transport.sqs.factory" class="Symfony\Component\Messenger\Bridge\AmazonSqs\Transport\AmazonSqsTransportFactory">
89+
<tag name="messenger.transport_factory" />
90+
</service>
91+
8892
<!-- retry -->
8993
<service id="messenger.retry_strategy_locator">
9094
<tag name="container.service_locator" />

0 commit comments

Comments
 (0)