Сообщение карты от SQS до DTO - PullRequest
0 голосов
/ 07 октября 2019

У меня есть очередь, которая подписана на тему 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() {}
}
...