From 7417162081eef52ca710448e3f8d3abd09c8394f Mon Sep 17 00:00:00 2001
From: jemin <jemin03120111@gmail.com>
Date: Sun, 28 Jan 2024 17:56:27 +0900
Subject: [PATCH] =?UTF-8?q?refactor:=20RedisEventPublisher=20=EB=AA=A8?=
 =?UTF-8?q?=EB=93=88=20=EB=B3=80=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

event publisher는 circuitbreaker 뿐만 아니라 다른 곳에서도 사용 되는 공통 기능이라 생각되 db-redis 모듈로 추출
---
 .../config/circuitbreaker/CircuitBreakerConfig.java       | 5 +++--
 .../mellyserver/dbredis/pubsub/RedisEventPublisher.java   | 8 ++++----
 2 files changed, 7 insertions(+), 6 deletions(-)
 rename core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerEventPublisher.java => storage/db-redis/src/main/java/cmc/mellyserver/dbredis/pubsub/RedisEventPublisher.java (71%)

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
index 5f4bf7d4..18c4baa7 100644
--- 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/core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerEventPublisher.java b/storage/db-redis/src/main/java/cmc/mellyserver/dbredis/pubsub/RedisEventPublisher.java
similarity index 71%
rename from core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerEventPublisher.java
rename to storage/db-redis/src/main/java/cmc/mellyserver/dbredis/pubsub/RedisEventPublisher.java
index b3c3a7ef..87dcc60b 100644
--- a/core/core-api/src/main/java/cmc/mellyserver/config/circuitbreaker/CircuitBreakerEventPublisher.java
+++ b/storage/db-redis/src/main/java/cmc/mellyserver/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;