6.5.5. 在 AWS SNS 主题和 AWS SQS Queue 之间创建一个订阅
您可以使用这种方式创建 SQS Queue 到 SNS 主题的订阅:
from("direct:start") .to("aws2-sns://test-camel-sns1?amazonSNSClient=#amazonSNSClient&subscribeSNStoSQS=true&queueUrl=https://sqs.eu-central-1.amazonaws.com/780410022472/test-camel");
#amazonSNSClient
是指 Registry 中的 SnsClient
。通过指定 subscribeSNStoSQS
to true 和现有 SQS Queue 的 queueUrl
,您可以将 SQS Queue 订阅到您的 SNS 主题。
此时,您可以使用来自 SNS Topic 通过 SQS Queue 的消息
from("aws2-sqs://test-camel?amazonSQSClient=#amazonSQSClient&delay=50&maxMessagesPerPoll=5") .to(...);