У меня есть очередь, которая подписана на тему SNS. Мне нужно получить часть сообщения SQS для сопоставления с моим DTO, но я не могу обернуть сообщение.
Вот что получает SQS:
{
"Type" : "Notification",
"MessageId" : "1ef7cd33-cdff-59b3-9a4a-9b3c12005fe9",
"Message" : "{\"outboundMessageId\":\"60fd1050-e5d1-401a-b1b2-426c07983e27\"}
}
Вотмой SQS Listener:
void updateResult(@NotificationSubject String subject,
@NotificationMessage ResultWrapper<ResultQueueDto> wrapper) {
ResultQueueDto messageDto = wrapper.getMessage();
}
ResultWrapper:
public class ResultWrapper<T> {
T message;
@JsonCreator
public ResultWrapper(@JsonProperty("Message") T message ){
this.message = message;
}
И DTO:
public class ResultQueueDto {
private UUID outboundMessageId;
public ResultQueueDto() {}
}