refactor: InflowGroupBucketService / InflowTargetBucketService AbstractInflowControlManager 타입 적용
서브모듈 리팩토링(AbstractInflowControlManager 분리)에 맞춰 InflowControlManager.getInstance() 호출을 InflowControlUtil.getInflowControlManager()로 변경. 반환 타입을 AbstractInflowControlManager로 통일. Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>
This commit is contained in:
+1
-1
Submodule elink-online-common updated: 9589bc635a...437961e7d5
@@ -5,15 +5,16 @@ import java.util.List;
|
|||||||
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
|
import com.eactive.eai.common.inflow.AbstractInflowControlManager;
|
||||||
import com.eactive.eai.common.inflow.CustomGroupBucket;
|
import com.eactive.eai.common.inflow.CustomGroupBucket;
|
||||||
import com.eactive.eai.common.inflow.InflowControlManager;
|
import com.eactive.eai.common.inflow.InflowControlUtil;
|
||||||
import com.eactive.eai.common.inflow.InflowGroupVO;
|
import com.eactive.eai.common.inflow.InflowGroupVO;
|
||||||
|
|
||||||
@Service
|
@Service
|
||||||
public class InflowGroupBucketService {
|
public class InflowGroupBucketService {
|
||||||
|
|
||||||
public GroupBucketStatusDTO getGroupBucketStatus(String groupId) {
|
public GroupBucketStatusDTO getGroupBucketStatus(String groupId) {
|
||||||
InflowControlManager manager = InflowControlManager.getInstance();
|
AbstractInflowControlManager manager = InflowControlUtil.getInflowControlManager();
|
||||||
|
|
||||||
InflowGroupVO groupVo = manager.getGroupInflowThreshold(groupId);
|
InflowGroupVO groupVo = manager.getGroupInflowThreshold(groupId);
|
||||||
if (groupVo == null) {
|
if (groupVo == null) {
|
||||||
@@ -71,11 +72,11 @@ public class InflowGroupBucketService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public CustomGroupBucket getCustomGroupBucket(String groupId) {
|
public CustomGroupBucket getCustomGroupBucket(String groupId) {
|
||||||
return InflowControlManager.getInstance().getGroupBucket(groupId);
|
return InflowControlUtil.getInflowControlManager().getGroupBucket(groupId);
|
||||||
}
|
}
|
||||||
|
|
||||||
public List<GroupBucketStatusDTO> getAllGroupBucketStatus() {
|
public List<GroupBucketStatusDTO> getAllGroupBucketStatus() {
|
||||||
InflowControlManager manager = InflowControlManager.getInstance();
|
AbstractInflowControlManager manager = InflowControlUtil.getInflowControlManager();
|
||||||
String[] groupIds = manager.getGroupAllKeys();
|
String[] groupIds = manager.getGroupAllKeys();
|
||||||
|
|
||||||
List<GroupBucketStatusDTO> result = new ArrayList<>();
|
List<GroupBucketStatusDTO> result = new ArrayList<>();
|
||||||
|
|||||||
@@ -6,7 +6,8 @@ import java.util.Map;
|
|||||||
|
|
||||||
import org.springframework.stereotype.Service;
|
import org.springframework.stereotype.Service;
|
||||||
|
|
||||||
import com.eactive.eai.common.inflow.InflowControlManager;
|
import com.eactive.eai.common.inflow.AbstractInflowControlManager;
|
||||||
|
import com.eactive.eai.common.inflow.InflowControlUtil;
|
||||||
import com.eactive.eai.common.inflow.InflowTargetVO;
|
import com.eactive.eai.common.inflow.InflowTargetVO;
|
||||||
import com.eactive.eai.common.inflow.dual.DualCustomBucket;
|
import com.eactive.eai.common.inflow.dual.DualCustomBucket;
|
||||||
import com.eactive.eai.common.inflow.dual.DualInflowControlManager;
|
import com.eactive.eai.common.inflow.dual.DualInflowControlManager;
|
||||||
@@ -79,7 +80,7 @@ public class InflowTargetBucketService {
|
|||||||
// -------------------------------------------------------------------------
|
// -------------------------------------------------------------------------
|
||||||
|
|
||||||
protected DualInflowControlManager getDualManager() {
|
protected DualInflowControlManager getDualManager() {
|
||||||
InflowControlManager base = InflowControlManager.getInstance();
|
AbstractInflowControlManager base = InflowControlUtil.getInflowControlManager();
|
||||||
return (base instanceof DualInflowControlManager) ? (DualInflowControlManager) base : null;
|
return (base instanceof DualInflowControlManager) ? (DualInflowControlManager) base : null;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user