0

我需要在 symfony messenger 中使用 SNS 的自定义传输来发布消息，但是当来自 SQS 的消费者收到消息时，应该处理该消息。我正在搜索这个特定的用例，但没有找到任何示例。信使的当前配置是：

framework:
    messenger:
        transports:
            sns:
                dsn: 'sns-transport://'
                options:
                    key: "%env(AWS_KEY)%"
                    secret: "%env(AWS_SECRET)%"
                    region: "%env(AWS_REGION)%"
                    topic: "%env(AWS_TOPIC_ARN)%"
                    endpoint: "%env(AWS_ENDPOINT)%"
        routing:
            'App\Domain\UserLogged': sns
            'App\Domain\UserRegistered': sns

4

0 回答 0