diff --git a/src/main/java/com/eactive/eai/common/circuitBreaker/type/TypedCircuitBreakerManager.java b/src/main/java/com/eactive/eai/common/circuitBreaker/type/TypedCircuitBreakerManager.java index f2c36bf..00ea5c0 100644 --- a/src/main/java/com/eactive/eai/common/circuitBreaker/type/TypedCircuitBreakerManager.java +++ b/src/main/java/com/eactive/eai/common/circuitBreaker/type/TypedCircuitBreakerManager.java @@ -17,10 +17,6 @@ import com.eactive.eai.common.lifecycle.LifecycleSupport; import com.eactive.eai.common.property.PropManager; import com.eactive.eai.common.util.ApplicationContextProvider; import com.eactive.eai.common.util.Logger; -import com.eactive.eai.custom.alarm.AlarmStateManager; -import com.eactive.eai.custom.alarm.condition.AlarmCondition; -import com.eactive.eai.custom.alarm.event.AlarmEvent; -import com.eactive.eai.custom.alarm.key.CoreAlarmKey; import com.fasterxml.jackson.databind.ObjectMapper; import com.fasterxml.jackson.databind.node.ObjectNode; @@ -45,7 +41,7 @@ public class TypedCircuitBreakerManager implements Lifecycle { TypedCircuitBreakerVO defaultConfigVo; HashMap idCBConfigMap = new HashMap<>(); HashMap apiIdCBConfigMap = new HashMap<>(); - HashMap urlCBConfigMap = new HashMap<>(); +// HashMap urlCBConfigMap = new HashMap<>(); private boolean started; @Autowired @@ -359,14 +355,15 @@ public class TypedCircuitBreakerManager implements Lifecycle { // } else { // this.sendAlert(stateTransitionEvent); // } - AlarmEvent alarmEvent = AlarmEvent.builder().key(CoreAlarmKey.CircuitBreaker) - .condition(AlarmCondition.builder().build()) - .message(String.format("CircuitBreaker state changed. apiId=%s, %s -> %s", event.getCircuitBreakerName(), fromState, toState)) - .build(); - - AlarmStateManager.getAlarmStateManager().onEvnet(alarmEvent); + +// AlarmEvent alarmEvent = AlarmEvent.builder().key(CoreAlarmKey.CircuitBreaker) +// .condition(AlarmCondition.builder().build()) +// .message(String.format("CircuitBreaker state changed. apiId=%s, %s -> %s", event.getCircuitBreakerName(), fromState, toState)) +// .build(); +// +// AlarmStateManager.getAlarmStateManager().onEvnet(alarmEvent); - logger.warn("CircuitBreaker state changed. apiId={}, {} -> {}", event.getCircuitBreakerName(), fromState, toState); + TypedCircuitBreakerManager.logger.warn("CircuitBreaker state changed. apiId={}, {} -> {}", event.getCircuitBreakerName(), fromState, toState); } else { TypedCircuitBreakerManager.logger.error(