diff --git a/src/main/java/com/eactive/eai/common/inflow/dual/DualRequestProcessor.java b/src/main/java/com/eactive/eai/inbound/processor/DualRequestProcessor.java similarity index 94% rename from src/main/java/com/eactive/eai/common/inflow/dual/DualRequestProcessor.java rename to src/main/java/com/eactive/eai/inbound/processor/DualRequestProcessor.java index add4e9e..318a326 100644 --- a/src/main/java/com/eactive/eai/common/inflow/dual/DualRequestProcessor.java +++ b/src/main/java/com/eactive/eai/inbound/processor/DualRequestProcessor.java @@ -1,11 +1,11 @@ -package com.eactive.eai.common.inflow.dual; +package com.eactive.eai.inbound.processor; import org.apache.commons.lang3.StringUtils; -import org.springframework.stereotype.Component; import com.eactive.eai.common.inflow.Bucket; import com.eactive.eai.common.inflow.InflowTargetVO; -import com.eactive.eai.inbound.processor.RequestProcessor; +import com.eactive.eai.common.inflow.dual.DualBucket; +import com.eactive.eai.common.inflow.dual.DualCustomBucket; /** * 어댑터/인터페이스 유량제어 차단 시 어느 버킷(PER_SECOND/THRESHOLD)에서 차단됐는지 @@ -18,7 +18,6 @@ import com.eactive.eai.inbound.processor.RequestProcessor; * *

Spring Bean 등록 후 기존 RequestProcessor 대신 이 클래스를 어댑터에 설정한다. */ -@Component("dualRequestProcessor") public class DualRequestProcessor extends RequestProcessor { @Override diff --git a/src/test/java/com/eactive/eai/common/inflow/dual/DualRequestProcessorTest.java b/src/test/java/com/eactive/eai/inbound/processor/DualRequestProcessorTest.java similarity index 98% rename from src/test/java/com/eactive/eai/common/inflow/dual/DualRequestProcessorTest.java rename to src/test/java/com/eactive/eai/inbound/processor/DualRequestProcessorTest.java index 7227ffb..ac6853d 100644 --- a/src/test/java/com/eactive/eai/common/inflow/dual/DualRequestProcessorTest.java +++ b/src/test/java/com/eactive/eai/inbound/processor/DualRequestProcessorTest.java @@ -1,4 +1,4 @@ -package com.eactive.eai.common.inflow.dual; +package com.eactive.eai.inbound.processor; import static org.junit.jupiter.api.Assertions.*; import static org.mockito.Mockito.*; @@ -10,6 +10,8 @@ import org.springframework.test.util.ReflectionTestUtils; import com.eactive.eai.common.inflow.Bucket; import com.eactive.eai.common.inflow.InflowTargetVO; +import com.eactive.eai.common.inflow.dual.DualBucket; +import com.eactive.eai.common.inflow.dual.DualCustomBucket; import com.eactive.eai.common.server.EAIServerManager; import com.eactive.eai.common.util.ApplicationContextProvider;