노승철 2 years ago
parent
commit
b2a63c95fc
  1. 3
      src/main/java/com/palnet/process/message/producer/MessageProducer.java
  2. 1
      src/main/java/com/palnet/server/command/SocketCommand.java

3
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")),

1
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);
}

Loading…
Cancel
Save