콘솔로의 메시지 송신 기능 개발

- 전송 이력 화면 진행중

src/docs/settings-examples/dfxagent-ami-dev.json

@@ -47,9 +47,9 @@
   ],
   "statusChecker": {
     "cron": "0/5 * * * * *",
-    "consoleHostName": "mkami.foxsoft.kr",
+    "consoleHostName": "1.220.99.10",
     "consoleListenPort": 17443,
-    "consoleSslEnabled": true
+    "consoleSslEnabled": false
   },
   "dataSourceConfig": [
     {

src/docs/settings-examples/dfxagent-mkami-dev.json

@@ -49,9 +49,9 @@
   ],
   "statusChecker": {
     "cron": "0/5 * * * * *",
-    "consoleHostName": "mkami.foxsoft.kr",
+    "consoleHostName": "192.168.0.16",
     "consoleListenPort": 17443,
-    "consoleSslEnabled": true
+    "consoleSslEnabled": false
   },
   "dataSourceConfig": [
     {

src/main/java/com/bsmlab/dfx/agent/listener/dto/ReceiveMessageDto.java

@@ -16,6 +16,7 @@ import java.util.Map;
 public class ReceiveMessageDto implements Serializable {
     private String senderHostId;
     private long senderTimestamp;
+    private String senderPostmanId;
     private String messageUuid;
     private AgentConfigDto.MessageType messageType;
     private long receivedTimestamp;

src/main/java/com/bsmlab/dfx/agent/task/dropbox/DropBoxSchedulerService.java

@@ -5,6 +5,7 @@ import com.bsmlab.dfx.agent.config.AgentConfigReader;
 import com.bsmlab.dfx.agent.config.datasource.SqlExecuteService;
 import com.bsmlab.dfx.agent.listener.dto.AckDto;
 import com.bsmlab.dfx.agent.listener.dto.ReceiveMessageDto;
+import com.bsmlab.dfx.agent.support.MessageUtils;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import io.micrometer.common.util.StringUtils;
@@ -122,6 +123,10 @@ public class DropBoxSchedulerService {
             receiveMessageDto.setProcessStatus(processStatus);
             this.ackDropBoxProcessResult(receiveMessageDto, processMessage);
         }
+        //2.1 콘솔에 연결되어 있는 경우 콘솔에도 메시지 전송
+        if(this.agentConfigReader.isConnectedConsole()) {
+            MessageUtils.announceMessageHistory(this.agentConfigReader, receiveMessageDto);
+        }
         //3. 처리한 메시지 이동
         try {
             boolean isSuccess = ReceiveMessageDto.ProcessStatus.PROCESS_DONE == processStatus; // PROCESS_DONE 이면 success 경로로 옮기고 아니면 failure 경로로 옮김

src/main/java/com/bsmlab/dfx/agent/task/postman/PostmanSchedulerService.java

@@ -92,7 +92,7 @@ public class PostmanSchedulerService {
                             routingHostList.add(routingHost);
                         }
                         ReceiveMessageDto receiveMessageDto = ReceiveMessageDto.builder().senderHostId(senderHostId).senderTimestamp(senderTimestamp)
-                                .messageUuid(messageUuid).messageType(AgentConfigDto.MessageType.TRANSFER_DB_TO_DB)
+                                .senderPostmanId(postman.getPostmanId()).messageUuid(messageUuid).messageType(AgentConfigDto.MessageType.TRANSFER_DB_TO_DB)
                                 .recipientHostId(postman.getRecipientHostId()).recipientDropBoxId(postman.getRecipientDropBoxId())
                                 .routingHostList(routingHostList)
                                 .data(dataString).build();