From 2ad9bd77a381e79d7899b06828503de289b40017 Mon Sep 17 00:00:00 2001
From: hyoseong-Choi <gytjd9516@naver.com>
Date: Wed, 19 Feb 2025 01:07:30 +0900
Subject: [PATCH] =?UTF-8?q?CLAP-480=20Fix=20:=20=EC=97=98=EB=9D=BC?=
 =?UTF-8?q?=EC=8A=A4=ED=8B=B1=EC=84=9C=EC=B9=98=20=EC=9E=A5=EC=8B=9C?=
 =?UTF-8?q?=EA=B0=84=20=EB=AF=B8=EC=82=AC=EC=9A=A9=EC=8B=9C=20=EC=97=B0?=
 =?UTF-8?q?=EA=B2=B0=20=EB=81=8A=EC=96=B4=EC=A7=80=EB=8A=94=20=EB=B2=84?=
 =?UTF-8?q?=EA=B7=B8=20=EC=88=98=EC=A0=95?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

<footer>
- #601
---
 .../ElasticsearchConnectionScheduler.java     | 25 +++++++++++++++++++
 1 file changed, 25 insertions(+)
 create mode 100644 src/main/java/clap/server/adapter/outbound/infrastructure/elastic/scheduler/ElasticsearchConnectionScheduler.java

diff --git a/src/main/java/clap/server/adapter/outbound/infrastructure/elastic/scheduler/ElasticsearchConnectionScheduler.java b/src/main/java/clap/server/adapter/outbound/infrastructure/elastic/scheduler/ElasticsearchConnectionScheduler.java
new file mode 100644
index 00000000..87e488e4
--- /dev/null
+++ b/src/main/java/clap/server/adapter/outbound/infrastructure/elastic/scheduler/ElasticsearchConnectionScheduler.java
@@ -0,0 +1,25 @@
+package clap.server.adapter.outbound.infrastructure.elastic.scheduler;
+
+import co.elastic.clients.elasticsearch.ElasticsearchClient;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+@Slf4j
+public class ElasticsearchConnectionScheduler {
+    private final ElasticsearchClient client;
+
+    @Scheduled(fixedRate = 30000)
+    public void keepConnectionAlive() {
+        try {
+            if (!client.ping().value()) {
+                log.error("Elasticsearch 연결 실패");
+            }
+        } catch (Exception e) {
+            log.error("Elasticsearch 연결 중 예외 발생: {}", e.getMessage());
+        }
+    }
+}