|
|
|
@ -3,6 +3,7 @@ package com.palnet.biz.message.consumer;
|
|
|
|
|
import com.fasterxml.jackson.databind.ObjectMapper; |
|
|
|
|
import com.palnet.biz.message.service.MessageService; |
|
|
|
|
import com.palnet.comn.model.GPDatabaseModel; |
|
|
|
|
import com.palnet.comn.utils.JsonUtils; |
|
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
|
import org.springframework.amqp.core.Message; |
|
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitHandler; |
|
|
|
@ -22,7 +23,7 @@ public class MessageConsumer {
|
|
|
|
|
|
|
|
|
|
public MessageConsumer(MessageService messageService, ObjectMapper objectMapper) { |
|
|
|
|
this.messageService = messageService; |
|
|
|
|
this.objectMapper = objectMapper; |
|
|
|
|
this.objectMapper = JsonUtils.getObjectMapper(); |
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
@RabbitHandler |
|
|
|
|