amazon-web-services - 如何在 Java 中为 SQS 队列订阅 SNS 主题

Question

当我创建一个新队列并将其订阅到 Java 主题时，没有消息出现。同样通过 AWS Web 控制台工作正常。

我想我必须以某种方式确认订阅，但是 sns.confirmSubscription方法需要一个 token - 我从哪里得到它？

这是我的Java代码:

String queueURL = sqs.createQueue("my-queue").getQueueUrl();

sns.subscribe(myTopicARN, "sqs", queueURL);

sns.publish(myTopicARN, "{\"payload\":\"test\"}");

sqs.receiveMessage(queueURL).getMessages()
        .forEach(System.out::println);  // nothing

我究竟做错了什么？

Answer 1

看看这个:https://aws.amazon.com/blogs/developer/subscribing-queues-to-topics/

你应该像这样订阅:

Topics.subscribeQueue(sns, sqs, myTopicARN, queueURL);

这种方便的方法为订阅创建了一个策略，以允许主题向队列发送消息。