6.5.5. AWS SNS Topic과 AWS SQS Queue 간의 서브스크립션 생성
다음과 같이 SNS 토픽에 SQS 큐의 서브스크립션을 생성할 수 있습니다.
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 는 레지스트리의 SnsClient 를 나타냅니다. subscribeSNStoSQS 를 true로 지정하고 기존 SQS 큐의 queueUrl 을 지정하면 SQS 큐를 SNS 토픽에 등록할 수 있습니다.
이 시점에서 SQS 큐를 통해 SNS 주제의 메시지를 사용할 수 있습니다.
from("aws2-sqs://test-camel?amazonSQSClient=#amazonSQSClient&delay=50&maxMessagesPerPoll=5")
.to(...);