diff --git a/src/main/java/com/palnet/process/message/producer/MessageProducer.java b/src/main/java/com/palnet/process/message/producer/MessageProducer.java index 50a9750..2cc23f2 100644 --- a/src/main/java/com/palnet/process/message/producer/MessageProducer.java +++ b/src/main/java/com/palnet/process/message/producer/MessageProducer.java @@ -5,6 +5,7 @@ import com.fasterxml.jackson.core.JsonProcessingException; import com.fasterxml.jackson.databind.ObjectMapper; import com.palnet.comn.model.GPModel; import com.palnet.process.message.Receiver; +import com.rabbitmq.client.Channel; import lombok.extern.slf4j.Slf4j; import org.springframework.amqp.rabbit.core.RabbitTemplate; import org.springframework.core.env.Environment; @@ -59,7 +60,7 @@ public class MessageProducer { e.printStackTrace(); } -// log.info("[WEBSOCKET MESSAGE] CONTROL DATA : {}" ,model); + log.info("Socket Payload : {}", json); rabbitTemplate.convertAndSend( Objects.requireNonNull(env.getProperty("message.websocket.exchange-name")), diff --git a/src/main/java/com/palnet/server/command/SocketCommand.java b/src/main/java/com/palnet/server/command/SocketCommand.java index 766b5a9..0b63dd4 100644 --- a/src/main/java/com/palnet/server/command/SocketCommand.java +++ b/src/main/java/com/palnet/server/command/SocketCommand.java @@ -138,6 +138,7 @@ public class SocketCommand { Long end = System.currentTimeMillis(); // logger.info(">>> during time : {}::{}", model.getObjectId(),end - start); // STEP 2. 이력 생성할 전문 전달 -> DRON의 대한 식별정보만 이력 관리 + if (model.getObjectId().indexOf("PALDRONE") > -1) { messageProducer.sendControlHistoryMessage(model); }