refactor: RedisEventPublisher 모듈 변경

event publisher는 circuitbreaker 뿐만 아니라 다른 곳에서도 사용 되는 공통 기능이라 생각되 db-redis 모듈로 추출
CMC11th-Melly · Jan 28, 2024 · 7417162 · 7417162
1 parent bdd954e
commit 7417162
Show file tree

Hide file tree

Showing 2 changed files with 7 additions and 6 deletions.
diff --git a/core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerConfig.java b/core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerConfig.java
@@ -6,6 +6,7 @@
 import org.springframework.context.annotation.Configuration;
 import org.springframework.data.redis.listener.ChannelTopic;
 
+import cmc.mellyserver.dbredis.pubsub.RedisEventPublisher;
 import io.github.resilience4j.circuitbreaker.CircuitBreaker;
 import io.github.resilience4j.circuitbreaker.event.CircuitBreakerOnStateTransitionEvent;
 import io.github.resilience4j.core.registry.EntryAddedEvent;
@@ -19,7 +20,7 @@
 public class CircuitBreakerConfig {
 
     @Bean
-    public RegistryEventConsumer<CircuitBreaker> myRegistryEventConsumer(CircuitBreakerEventPublisher redisPublisher) {
+    public RegistryEventConsumer<CircuitBreaker> myRegistryEventConsumer(RedisEventPublisher redisPublisher) {
 
         return new RegistryEventConsumer<CircuitBreaker>() {
             @Override
@@ -45,7 +46,7 @@ public void onEntryReplacedEvent(EntryReplacedEvent<CircuitBreaker> entryReplace
     }
 
     private void publishCircuitOpenTopic(CircuitBreakerOnStateTransitionEvent event,
-        CircuitBreakerEventPublisher redisPublisher) {
+        RedisEventPublisher redisPublisher) {
         if (openStateSpreadEnabled(event)) {
             redisPublisher.publish(new ChannelTopic(CIRCUIT_OPEN), event.getCircuitBreakerName());
         }

diff --git a/...breaker/CircuitBreakerEventPublisher.java → ...r/dbredis/pubsub/RedisEventPublisher.java b/...breaker/CircuitBreakerEventPublisher.java → ...r/dbredis/pubsub/RedisEventPublisher.java
@@ -1,14 +1,14 @@
-package cmc.mellyserver.config.circuitbreaker;
+package cmc.mellyserver.dbredis.pubsub;
 
 import org.springframework.data.redis.core.RedisTemplate;
 import org.springframework.data.redis.listener.ChannelTopic;
-import org.springframework.stereotype.Service;
+import org.springframework.stereotype.Component;
 
 import lombok.RequiredArgsConstructor;
 
-@Service
+@Component
 @RequiredArgsConstructor
-public class CircuitBreakerEventPublisher {
+public class RedisEventPublisher {
 
     private final RedisTemplate redisTemplate;