Используя методPublishMessage(), я могу создавать динамические темы, подписываясь на динамические очереди, но SNS не публикует сообщения в sqs. Какие здесь проблемы?
public void publishMessage(String topicName, String message) {
String topicArn = createTopic(topicName);
subSQS(topicArn);
pubTopic(message, topicArn);
}
private String createTopic(String topicName) {
CreateTopicResponse result = null;
CreateTopicRequest request = CreateTopicRequest.builder()
.name(topicName)
.build();
result = snsClient.createTopic(request);
return result.topicArn();
}
private void pubTopic(String message, String topicArn) {
PublishRequest request = PublishRequest.builder()
.message(message)
.topicArn(topicArn)
.build();
PublishResponse result = this.snsClient.publish(request);
log.info(result.messageId() + " Message sent. Status is " + result.sdkHttpResponse().statusCode());
}
private void subSQS(String topicArn) {
String sqsTopic = topicArn.replace("sns", "sqs");
try {
SubscribeRequest request = SubscribeRequest.builder()
.protocol("sqs")
.endpoint(sqsTopic)
.returnSubscriptionArn(true)
.topicArn(topicArn)
.build();
SubscribeResponse result = snsClient.subscribe(request);
System.out.println("Subscription ARN: " + result.subscriptionArn() + "\n\n Status is " + result.sdkHttpResponse().statusCode());
} catch (SnsException e) {
System.err.println(e.awsErrorDetails().errorMessage());
System.exit(1);
}
}
Подробнее здесь: https://stackoverflow.com/questions/787 ... age-to-sqs
