djb-eapim/eapim-admin
1
0
Fork 0
Code Issues Pull Requests Actions 5 Packages Projects Releases Wiki Activity

- 메모리 리로드 비정상 동작하는 부분 수정, 기존 코드 사용.

Browse Source
This commit is contained in:
daekuk
2026-01-30 10:45:21 +09:00
parent 51bbd6678b
commit 9943c44eb4
2 changed files with 44 additions and 32 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterController.java
+1 -1
View File
@@ -248,7 +248,7 @@ public class AdapterController extends OnlBaseAnnotationController {
synchronized (obj) { synchronized (obj) {
service.update(adapterGroupUI); service.update(adapterGroupUI);
Map<String, String> resultMap = service.reloadSyncStdMsgAndAdapter(adapterGroupUI.getAdptrbzwkgroupname()); Map<String, String> resultMap = service.reloadSyncStdMsgAndAdapter(adapterGroupUI);
return ResponseEntity.ok(resultMap); return ResponseEntity.ok(resultMap);
} }
src/main/java/com/eactive/eai/rms/onl/manage/adapter/adapter/AdapterManService.java
+37 -25
View File
@@ -540,40 +540,52 @@ public class AdapterManService extends OnlBaseService {
} }
} }
public Map<String, String> reloadSyncStdMsgAndAdapter(String adapterGroupName) throws Exception { public Map<String, String> reloadSyncStdMsgAndAdapter(AdapterGroupUI adapterGroupUI) throws Exception {
Map<String, Object> receive = null;
Map<String, String> result = new HashMap<>();
String status = "success";
Map<String, String> result = new HashMap<>(); try {
log.info(">>>>>> [Reload AdapterManService Start] 리로드 시작");
String status = "success"; for (Entry<String, AdapterUI> entry : adapterGroupUI.getAdapterData().entrySet()) {
AdapterUI adapterUI = entry.getValue();
String prptyGroupName = adapterUI.getPrptygroupname();
try { CommonCommand pcommand = new CommonCommand(
log.debug(">>>>>>>> [Reload Start] 어댑터 그룹명 {}", adapterGroupName); "com.eactive.eai.agent.adapter.ReloadAdapterPropGroupCommand",
prptyGroupName
);
agentUtilService.broadcast(pcommand);
}
CommonCommand pcommand = new CommonCommand( // 어댑터 그룹 리로드
"com.eactive.eai.agent.adapter.ReloadAdapterPropGroupCommand", CommonCommand acommand = new CommonCommand(
adapterGroupName "com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand",
); adapterGroupUI.getAdptrbzwkgroupname()
agentUtilService.broadcast(pcommand); );
receive = agentUtilService.broadcast(acommand);
CommonCommand acommand = new CommonCommand( // HS04 API_FULL_PATH
"com.eactive.eai.agent.adapter.ReloadAdapterGroupCommand", Command stdcommand = new ReloadSTDMessageCommand();
adapterGroupName stdcommand.setArgs("ALL");
);
agentUtilService.broadcast(acommand);
Command stdcommand = new ReloadSTDMessageCommand();
stdcommand.setArgs("ALL");
agentUtilService.broadcast(stdcommand); agentUtilService.broadcast(stdcommand);
log.info(">>>>>> [Reload End] 모든 리로드 명령 전송 완료"); log.info(">>>>>> [Reload AdapterManService End] 리로드 완료");
} catch (Exception e) {
status = "error";
log.error("리로드 실패", e);
}
result.put("status", status); } catch (Exception e) {
return result; 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<String, String> reloadSync(AdapterGroupUI adapterGroupUI) throws Exception { public Map<String, String> reloadSync(AdapterGroupUI adapterGroupUI) throws Exception {