|
|
@ -5,15 +5,13 @@ import com.fasterxml.jackson.databind.ObjectMapper; |
|
|
|
import com.palnet.comn.model.CtrCntrlModel; |
|
|
|
import com.palnet.comn.model.CtrCntrlModel; |
|
|
|
import com.palnet.comn.model.GPHistoryShareContext; |
|
|
|
import com.palnet.comn.model.GPHistoryShareContext; |
|
|
|
import com.palnet.comn.model.GPDatabaseModel; |
|
|
|
import com.palnet.comn.model.GPDatabaseModel; |
|
|
|
|
|
|
|
import com.palnet.comn.utils.JsonUtils; |
|
|
|
import com.palnet.server.collection.ChannelCollection; |
|
|
|
import com.palnet.server.collection.ChannelCollection; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import lombok.extern.slf4j.Slf4j; |
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitHandler; |
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitHandler; |
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|
|
|
import org.springframework.amqp.rabbit.annotation.RabbitListener; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
import org.springframework.stereotype.Component; |
|
|
|
|
|
|
|
|
|
|
|
import java.util.ArrayList; |
|
|
|
|
|
|
|
import java.util.List; |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
@Component |
|
|
|
@Component |
|
|
|
@Slf4j |
|
|
|
@Slf4j |
|
|
|
public class MessageConsumer { |
|
|
|
public class MessageConsumer { |
|
|
@ -23,8 +21,8 @@ public class MessageConsumer { |
|
|
|
private final ObjectMapper objectMapper; |
|
|
|
private final ObjectMapper objectMapper; |
|
|
|
private final GPHistoryShareContext gpHistoryShareModel; |
|
|
|
private final GPHistoryShareContext gpHistoryShareModel; |
|
|
|
|
|
|
|
|
|
|
|
public MessageConsumer(ObjectMapper objectMapper, GPHistoryShareContext gpHistoryShareModel) { |
|
|
|
public MessageConsumer(GPHistoryShareContext gpHistoryShareModel) { |
|
|
|
this.objectMapper = objectMapper; |
|
|
|
this.objectMapper = JsonUtils.getObjectMapper(); |
|
|
|
this.gpHistoryShareModel = gpHistoryShareModel; |
|
|
|
this.gpHistoryShareModel = gpHistoryShareModel; |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|