Refactor: 커넥터 시작·종료 제어를 단일 진입점으로 위임

Co-Authored-By: Claude Sonnet 4.6 <noreply@anthropic.com>

Author: SimoKii

src/main/java/com/rabbittick/streamer/connector/ConnectorManager.java

@@ -0,0 +1,42 @@
+package com.rabbittick.streamer.connector;
+
+import java.util.List;
+
+import org.springframework.boot.context.event.ApplicationReadyEvent;
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Component;
+
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * 등록된 모든 {@link ExchangeConnector}의 시작과 종료를 조율하는 컴포넌트.
+ *
+ * <p>Spring이 {@code List<ExchangeConnector>}를 자동 주입하므로
+ * 새로운 거래소 커넥터를 추가하면 이 클래스의 수정 없이 자동으로 관리 대상에 포함된다.
+ */
+@Slf4j
+@Component
+public class ConnectorManager {
+
+    private final List<ExchangeConnector> connectors;
+
+    public ConnectorManager(List<ExchangeConnector> connectors) {
+        this.connectors = connectors;
+    }
+
+    /**
+     * Spring 애플리케이션이 완전히 준비된 후 활성화된 모든 커넥터를 시작한다.
+     *
+     * @param event Spring 애플리케이션 준비 완료 이벤트
+     */
+    @EventListener(ApplicationReadyEvent.class)
+    public void startAll(ApplicationReadyEvent event) {
+        log.info("ConnectorManager: 등록된 커넥터 {}개 중 활성화된 커넥터를 시작합니다.", connectors.size());
+        connectors.stream()
+            .filter(ExchangeConnector::isEnabled)
+            .forEach(connector -> {
+                log.info("[{}] 커넥터 시작", connector.getExchangeName());
+                connector.start();
+            });
+    }
+}

src/main/java/com/rabbittick/streamer/connector/UpbitConnector.java

@@ -8,8 +8,6 @@
 
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.beans.factory.annotation.Value;
-import org.springframework.boot.context.event.ApplicationReadyEvent;
-import org.springframework.context.event.EventListener;
 import org.springframework.core.env.Environment;
 import org.springframework.stereotype.Component;
 import org.springframework.web.reactive.socket.WebSocketSession;
@@ -104,22 +102,6 @@ public UpbitConnector(WebSocketClient webSocketClient,
         this.objectMapper = objectMapper;
     }
 
-    /**
-     * Spring 애플리케이션이 완전히 준비된 후 WebSocket 연결을 시작한다.
-     *
-     * <p>Commit 4에서 {@code ConnectorManager}로 이관 예정.
-     *
-     * @param event Spring 애플리케이션 준비 완료 이벤트
-     */
-    @EventListener(ApplicationReadyEvent.class)
-    public void startWebSocketConnection(ApplicationReadyEvent event) {
-        log.debug("설정 로드 확인 - tickerEnabled: {}, tradeEnabled: {}, orderbookEnabled: {}",
-            tickerEnabled, tradeEnabled, orderbookEnabled);
-        log.info("활성화된 데이터 타입 - Ticker: {}, Trade: {}, OrderBook: {}",
-            tickerEnabled, tradeEnabled, orderbookEnabled);
-        start();
-    }
-
     @Override
     public String getExchangeName() {
         return "UPBIT";