兔子在春季检索一个物体

Question

我有一个正在使用@rabbitlistener注释的消费者类，我需要检索我在有效载荷中获得的对象：

@Component
public class RabbitMQService {

    private final Logger logger = LoggerFactory.getLogger(RabbitMQService.class);

    @RabbitListener(queues = "${peopleevents.queue}")
    public void receivedMessage(@Payload Message message) throws JsonProcessingException {

        String json = "";

        json = new String(message.getBody(), StandardCharsets.UTF_8);

        logger.info("Received message: {}", json);

        ObjectMapper objectMapper = new ObjectMapper();
        PeopleCoresConsumerDTO consumerDTO = objectMapper.readValue(json, PeopleCoresConsumerDTO.class);
        logger.info("Received message is.. " + message.toString());
    }

我正在使用objectMapper来获取它，但我认为我在这里缺少一些东西来完全检索对象回来，但我不知道吗？有帮助！??

DTO如下：

@Data
@NoArgsConstructor
@AllArgsConstructor
@JsonIgnoreProperties(ignoreUnknown=true)
@JsonInclude(JsonInclude.Include.NON_NULL)
public class PeopleCoresConsumerDTO {

    @JsonProperty(value = "processType")
    @NotNull(message = "ProcessType is mandatory")
    private String processType;

    @JsonProperty(value = "operation")
    @NotNull(message = "Operation is mandatory")
    private String operation;

    @JsonProperty(value = "Entity")
    @NotNull(message = "Entity is mandatory")
    private String entity;

    @JsonProperty(value = "EntityType")
    @NotNull(message = "EntityType is mandatory")
    private String entityType;

    @JsonProperty(value = "IdCuco")
    @NotNull(message = "IdCuco is mandatory")
    private Long idCuco;

    @JsonProperty(value = "PersonF")
    private PersonF personF;

    @JsonProperty(value = "Address")
    private Address address;

    @JsonProperty(value = "Document")
    private Document document;

    @JsonProperty(value = "Ban")
    private Ban ban;

    @JsonProperty(value = "Dates")
    private PeopleDate date;

    @Getter
    @Setter
    class Customer {
        private String systemId;
        private String customerId;
    }

    private List<Customer> customers;

}

Answer 1

只需将jackson2jsonmessageconverter @bean添加到上下文中，然后

@RabbitListener(queues = "${peopleevents.queue}")
public void receivedMessage(@Payload PeopleCoresConsumerDTO consumerDTO) {
   ...
}