From 9943c44eb40985e27369c81af95893c4b3618d35 Mon Sep 17 00:00:00 2001 From: daekuk Date: Fri, 30 Jan 2026 10:45:21 +0900 Subject: [PATCH] =?UTF-8?q?-=20=EB=A9=94=EB=AA=A8=EB=A6=AC=20=EB=A6=AC?= =?UTF-8?q?=EB=A1=9C=EB=93=9C=20=EB=B9=84=EC=A0=95=EC=83=81=20=EB=8F=99?= =?UTF-8?q?=EC=9E=91=ED=95=98=EB=8A=94=20=EB=B6=80=EB=B6=84=20=EC=88=98?= =?UTF-8?q?=EC=A0=95,=20=EA=B8=B0=EC=A1=B4=20=EC=BD=94=EB=93=9C=20?= =?UTF-8?q?=EC=82=AC=EC=9A=A9.?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../adapter/adapter/AdapterController.java | 2 +- .../adapter/adapter/AdapterManService.java | 74 +++++++++++-------- 2 files changed, 44 insertions(+), 32 deletions(-) diff --git a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java index 338f5d5..77dd89d 100644 --- a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java +++ b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java @@ -248,7 +248,7 @@ public class AdapterController extends OnlBaseAnnotationController { synchronized (obj) { service.update(adapterGroupUI); - Map resultMap = service.reloadSyncStdMsgAndAdapter(adapterGroupUI.getAdptrbzwkgroupname()); + Map resultMap = service.reloadSyncStdMsgAndAdapter(adapterGroupUI); return ResponseEntity.ok(resultMap); } diff --git a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java index 7de3d7b..d55875d 100644 --- a/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java +++ b/src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java @@ -540,40 +540,52 @@ public class AdapterManService extends OnlBaseService { } } - public Map reloadSyncStdMsgAndAdapter(String adapterGroupName) throws Exception { - - Map result = new HashMap<>(); - - String status = "success"; - - try { - log.debug(">>>>>>>> [Reload Start] 어댑터 그룹명 {}", adapterGroupName); - - CommonCommand pcommand = new CommonCommand( - "com.eactive.eai.agent.adapter.ReloadAdapterPropGroupCommand", - adapterGroupName - ); - agentUtilService.broadcast(pcommand); - - CommonCommand acommand = new CommonCommand( - "com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand", - adapterGroupName - ); - agentUtilService.broadcast(acommand); - - Command stdcommand = new ReloadSTDMessageCommand(); - stdcommand.setArgs("ALL"); + public Map reloadSyncStdMsgAndAdapter(AdapterGroupUI adapterGroupUI) throws Exception { + Map receive = null; + Map result = new HashMap<>(); + String status = "success"; + + try { + log.info(">>>>>> [Reload AdapterManService Start] 리로드 시작"); + + for (Entry entry : adapterGroupUI.getAdapterData().entrySet()) { + AdapterUI adapterUI = entry.getValue(); + String prptyGroupName = adapterUI.getPrptygroupname(); + + CommonCommand pcommand = new CommonCommand( + "com.eactive.eai.agent.adapter.ReloadAdapterPropGroupCommand", + prptyGroupName + ); + agentUtilService.broadcast(pcommand); + } + + // 어댑터 그룹 리로드 + CommonCommand acommand = new CommonCommand( + "com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand", + adapterGroupUI.getAdptrbzwkgroupname() + ); + receive = agentUtilService.broadcast(acommand); + + // HS04 API_FULL_PATH + Command stdcommand = new ReloadSTDMessageCommand(); + stdcommand.setArgs("ALL"); agentUtilService.broadcast(stdcommand); - log.info(">>>>>> [Reload End] 모든 리로드 명령 전송 완료"); - } catch (Exception e) { - status = "error"; - log.error("리로드 실패", e); - } - - result.put("status", status); - return result; + log.info(">>>>>> [Reload AdapterManService End] 리로드 완료"); + } catch (Exception e) { + status = "error"; + log.error("리로드 실패", e); + } + + if (receive != null && receive.values().stream().anyMatch(value -> value == null || !"success".equals(value))) { + status = "error"; + } + + result.put("status", status); + if(receive != null) result.put("message", receive.toString()); + + return result; } public Map reloadSync(AdapterGroupUI adapterGroupUI) throws Exception {