[BE] 입장 10분 전 푸시 알림 전송 기능 구현 (#483)

backend/src/main/java/com/festago/config/AsyncConfig.java

@@ -1,32 +1,10 @@
 package com.festago.config;
 
-import java.util.concurrent.Executor;
-import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableAsync;
-import org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor;
 
 @EnableAsync
 @Configuration
 public class AsyncConfig {
 
-    private static final String DEFAULT_EXECUTOR_NAME = "taskExecutor";
-    public static final String FCM_EXECUTOR_NAME = "fcmExecutor";
-
-    @Bean(name = DEFAULT_EXECUTOR_NAME)
-    public Executor defaultExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(8);
-        executor.initialize();
-        return executor;
-    }
-
-    @Bean(name = FCM_EXECUTOR_NAME)
-    public Executor fcmExecutor() {
-        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
-        executor.setCorePoolSize(8);
-        executor.setQueueCapacity(10);
-        executor.initialize();
-        return executor;
-    }
 }

backend/src/main/java/com/festago/entry_alert/application/EntryAlertService.java

@@ -65,7 +65,7 @@ public void sendEntryAlert(Long id) {
     private void sendMessages(List<String> tokens) {
         for (int i = 0; i < tokens.size(); i += BATCH_ALERT_SIZE) {
             List<String> subTokens = tokens.subList(i, Math.min(i + BATCH_ALERT_SIZE, tokens.size()));
-            fcmClient.sendAll(subTokens, FCMChannel.ENTRY_ALERT, FcmPayload.entryAlert());
+            fcmClient.sendAllAsync(subTokens, FCMChannel.ENTRY_ALERT, FcmPayload.entryAlert());
         }
     }
 }

backend/src/main/java/com/festago/fcm/application/FCMNotificationEventListener.java

@@ -1,6 +1,5 @@
 package com.festago.fcm.application;
 
-import com.festago.config.AsyncConfig;
 import com.festago.entry.dto.event.EntryProcessEvent;
 import com.festago.fcm.domain.FCMChannel;
 import com.festago.fcm.dto.FcmPayload;
@@ -23,7 +22,7 @@ public FCMNotificationEventListener(FcmClient fcmClient, MemberFCMService member
     }
 
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMMIT)
-    @Async(value = AsyncConfig.FCM_EXECUTOR_NAME)
+    @Async
     public void sendFcmNotification(EntryProcessEvent event) {
         List<String> tokens = getMemberFCMToken(event.memberId());
         fcmClient.sendAll(tokens, FCMChannel.ENTRY_PROCESS, FcmPayload.entryProcess());

backend/src/main/java/com/festago/fcm/application/FcmClient.java

@@ -5,6 +5,8 @@
 import java.util.List;
 
 public interface FcmClient {
-
+
+    void sendAllAsync(List<String> tokens, FCMChannel channel, FcmPayload fcmPayload);
+
     void sendAll(List<String> tokens, FCMChannel channel, FcmPayload fcmPayload);
 }

backend/src/main/java/com/festago/fcm/application/MockFcmClient.java

@@ -1,6 +1,5 @@
 package com.festago.fcm.application;
 
-import com.festago.config.AsyncConfig;
 import com.festago.fcm.domain.FCMChannel;
 import com.festago.fcm.dto.FcmPayload;
 import java.util.List;
@@ -17,7 +16,12 @@ public class MockFcmClient implements FcmClient {
     private static final Logger log = LoggerFactory.getLogger(MockFcmClient.class);
 
     @Override
-    @Async(value = AsyncConfig.FCM_EXECUTOR_NAME)
+    @Async
+    public void sendAllAsync(List<String> tokens, FCMChannel channel, FcmPayload fcmPayload) {
+        sendAll(tokens, channel, fcmPayload);
+    }
+
+    @Override
     public void sendAll(List<String> tokens, FCMChannel channel, FcmPayload fcmPayload) {
         log.info("[FCM] title: {} / body: {} / to {} device", fcmPayload.title(), fcmPayload.body(), tokens.size());
     }

backend/src/main/java/com/festago/fcm/infrastructure/FcmClientImpl.java

@@ -2,7 +2,6 @@
 
 import com.festago.common.exception.ErrorCode;
 import com.festago.common.exception.InternalServerException;
-import com.festago.config.AsyncConfig;
 import com.festago.fcm.application.FcmClient;
 import com.festago.fcm.domain.FCMChannel;
 import com.festago.fcm.dto.FcmPayload;
@@ -33,7 +32,12 @@ public FcmClientImpl(FirebaseMessaging firebaseMessaging) {
     }
 
     @Override
-    @Async(value = AsyncConfig.FCM_EXECUTOR_NAME)
+    @Async
+    public void sendAllAsync(List<String> tokens, FCMChannel channel, FcmPayload fcmPayload) {
+        sendAll(tokens, channel, fcmPayload);
+    }
+
+    @Override
     public void sendAll(List<String> tokens, FCMChannel channel, FcmPayload payload) {
         List<Message> messages = createMessages(tokens, channel, payload);
         try {