diff --git a/meeting/src/main/java/com/unicorn/hgzero/meeting/infra/config/EventHubConfig.java b/meeting/src/main/java/com/unicorn/hgzero/meeting/infra/config/EventHubConfig.java index cafbbf4..41d452d 100644 --- a/meeting/src/main/java/com/unicorn/hgzero/meeting/infra/config/EventHubConfig.java +++ b/meeting/src/main/java/com/unicorn/hgzero/meeting/infra/config/EventHubConfig.java @@ -15,7 +15,7 @@ import org.springframework.context.annotation.Configuration; */ @Configuration @Slf4j -@org.springframework.boot.autoconfigure.condition.ConditionalOnExpression("'${eventhub.connection-string:}'.length() > 0") +@ConditionalOnProperty(name = "eventhub.connection-string") public class EventHubConfig { @Value("${eventhub.connection-string}") diff --git a/rag/src/services/eventhub_consumer.py b/rag/src/services/eventhub_consumer.py index 2b784ab6..dddc17f 100644 --- a/rag/src/services/eventhub_consumer.py +++ b/rag/src/services/eventhub_consumer.py @@ -294,7 +294,7 @@ class EventHubConsumer: # 7. SSE를 통해 결과 전송 # Event Hub 메시지에서 sessionId 추출 (여러 필드 확인) - session_id = event_data.get("sessionId") + session_id = event_data.get("meetingId") # front 요청(회의 주최자만 확인 가능 이슈)으로 이벤트의 sessionId 기준이 아닌 meetingId 기준으로 SSE 연동 # session_id = event_data.get("sessionId") or event_data.get("session_id") or event_data.get("meetingId") or meeting_id logger.info(f"SSE 전송 시도: sessionId={session_id}, meetingId={meeting_id}")