6.5.5. 在 AWS SNS Topic 和 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
。通过将 subscribeSNStoSQSQS
设置为 true,并且现有 SQS Queue 的 queueUrl
,您将能够在您的 SNS 主题中订阅您的 SQS Queue。
此时,您可以使用来自 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(...);