유량제어 모니터링

src/main/java/com/eactive/eai/rms/onl/manage/inflow/inflow/InflowAdapterControlManController.java

@@ -86,8 +86,8 @@ public class InflowAdapterControlManController extends OnlBaseAnnotationControll
 	}
 
 	@RequestMapping(value = "/onl/admin/inflow/inflowAdapterControlMan.json", params = "cmd=LIST_BUCKET_STATUS")
-	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response) {
-		List<Map<String, Object>> statusList = service.getAdapterBucketStatus();
+	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response, String adapterId) {
+		List<Map<String, Object>> statusList = service.getAdapterBucketStatus(adapterId);
 		Map<String, Object> resultMap = new HashMap<>();
 		resultMap.put("servers", statusList);
 		return new ModelAndView("jsonView", resultMap);

src/main/java/com/eactive/eai/rms/onl/manage/inflow/inflow/InflowClientControlManController.java

@@ -84,8 +84,8 @@ public class InflowClientControlManController extends OnlBaseAnnotationControlle
 	}
 
 	@RequestMapping(value = "/onl/admin/inflow/inflowClientControlMan.json", params = "cmd=LIST_BUCKET_STATUS")
-	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response) {
-		List<Map<String, Object>> statusList = service.getClientBucketStatus();
+	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response, String clientId) {
+		List<Map<String, Object>> statusList = service.getClientBucketStatus(clientId);
 		Map<String, Object> resultMap = new HashMap<>();
 		resultMap.put("servers", statusList);
 		return new ModelAndView("jsonView", resultMap);

src/main/java/com/eactive/eai/rms/onl/manage/inflow/inflow/InflowControlManService.java

@@ -142,22 +142,22 @@ public class InflowControlManService extends BaseService {
 	}
 
 	@SuppressWarnings("unchecked")
-	public List<Map<String, Object>> getClientBucketStatus() {
-		return getBucketStatus("client", "클라이언트가 로드되지 않음", "클라이언트 버킷 상태 조회 실패");
+	public List<Map<String, Object>> getClientBucketStatus(String clientId) {
+		return getBucketStatus("client", clientId, "클라이언트가 로드되지 않음", "클라이언트 버킷 상태 조회 실패");
 	}
 
 	@SuppressWarnings("unchecked")
-	public List<Map<String, Object>> getAdapterBucketStatus() {
-		return getBucketStatus("adapter", "어댑터가 로드되지 않음", "어댑터 버킷 상태 조회 실패");
+	public List<Map<String, Object>> getAdapterBucketStatus(String adapterId) {
+		return getBucketStatus("adapter", adapterId, "어댑터가 로드되지 않음", "어댑터 버킷 상태 조회 실패");
 	}
 
 	@SuppressWarnings("unchecked")
-	public List<Map<String, Object>> getInterfaceBucketStatus() {
-		return getBucketStatus("interface", "인터페이스가 로드되지 않음", "인터페이스 버킷 상태 조회 실패");
+	public List<Map<String, Object>> getInterfaceBucketStatus(String interfaceId) {
+		return getBucketStatus("interface", interfaceId, "인터페이스가 로드되지 않음", "인터페이스 버킷 상태 조회 실패");
 	}
 
 	@SuppressWarnings("unchecked")
-	private List<Map<String, Object>> getBucketStatus(String type, String noDataMessage, String logPrefix) {
+	private List<Map<String, Object>> getBucketStatus(String target, String targetId, String noDataMessage, String logPrefix) {
 		List<Map<String, Object>> result = new ArrayList<>();
 		List<Map<String, String>> serverList = eaiServerInfoService.getEaiServerIpList();
 
@@ -176,8 +176,8 @@ public class InflowControlManService extends BaseService {
 			serverStatus.put("serverPort", serverPort);
 
 			try {
-				String url = String.format("http://%s:%s/manage/inflow/%s/bucket-status",
-						serverIp, serverPort, type);
+				String url = String.format("http://%s:%s/manage/inflow/%s/%s/bucket-status",
+						serverIp, serverPort, target, targetId);
 				ResponseEntity<Map> response = restTemplate.getForEntity(url, Map.class);
 
 				if (response.getBody() != null && Boolean.TRUE.equals(response.getBody().get("success"))) {

src/main/java/com/eactive/eai/rms/onl/manage/inflow/inflow/InflowInterfaceControlManController.java

@@ -84,8 +84,8 @@ public class InflowInterfaceControlManController extends OnlBaseAnnotationContro
 	}
 
 	@RequestMapping(value = "/onl/admin/inflow/inflowInterfaceControlMan.json", params = "cmd=LIST_BUCKET_STATUS")
-	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response) {
-		List<Map<String, Object>> statusList = service.getInterfaceBucketStatus();
+	public ModelAndView getBucketStatus(HttpServletRequest request, HttpServletResponse response, String interfaceId) {
+		List<Map<String, Object>> statusList = service.getInterfaceBucketStatus(interfaceId);
 		Map<String, Object> resultMap = new HashMap<>();
 		resultMap.put("servers", statusList);
 		return new ModelAndView("jsonView", resultMap);