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");
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(...);
from("aws2-sqs://test-camel?amazonSQSClient=#amazonSQSClient&delay=50&maxMessagesPerPoll=5")
.to(...);