Merge pull request #17 from kw-notice/refactor/issue-13

batch application component scan error and timeout logic refactoring

domain/alarm/src/main/kotlin/com/knet/dormitory/domain/alarm/AlarmService.kt

@@ -4,6 +4,7 @@ import com.google.firebase.messaging.AndroidConfig
 import com.google.firebase.messaging.AndroidNotification
 import com.google.firebase.messaging.FirebaseMessaging
 import com.google.firebase.messaging.Message
+import kotlinx.coroutines.withTimeout
 import org.slf4j.LoggerFactory
 import org.springframework.stereotype.Service
 
@@ -13,7 +14,7 @@ class AlarmService(
 ) {
     private val logger = LoggerFactory.getLogger(AlarmService::class.java)
 
-    suspend fun sendMessage(title: String, body: String, topic: AlarmTopic) {
+    suspend fun sendMessage(title: String, body: String, topic: AlarmTopic) = withTimeout(2000L) {
         val notification = AndroidNotification.builder()
             .setChannelId("kw_dormitory_notice_id")
             .setTitle(title)

domain/notice/src/main/kotlin/com/knet/dormitory/config/WebClientConfig.kt

@@ -2,10 +2,18 @@ package com.knet.dormitory.config
 
 import org.springframework.context.annotation.Bean
 import org.springframework.context.annotation.Configuration
+import org.springframework.web.reactive.function.client.ExchangeStrategies
 import org.springframework.web.reactive.function.client.WebClient
 
 @Configuration
 class WebClientConfig {
     @Bean
-    fun webClient():WebClient = WebClient.create()
+    fun webClient(): WebClient {
+        val exchangeStrategies = ExchangeStrategies.builder()
+            .codecs { configurer -> configurer.defaultCodecs().maxInMemorySize(-1) }
+            .build()
+        return WebClient.builder()
+            .exchangeStrategies(exchangeStrategies)
+            .build()
+    }
 }

web/batch-server/src/main/kotlin/com/knet/batch/DormitoryBatchApplication.kt

@@ -3,7 +3,7 @@ package com.knet.batch
 import org.springframework.boot.autoconfigure.SpringBootApplication
 import org.springframework.boot.runApplication
 
-@SpringBootApplication(scanBasePackages = ["com.knet.dormitory"])
+@SpringBootApplication(scanBasePackages = ["com.knet"])
 class DormitoryBatchApplication
 
 fun main(args: Array<String>) {

web/batch-server/src/main/kotlin/com/knet/batch/config/DormitorySchedulingConfig.kt

@@ -32,7 +32,7 @@ class DormitorySchedulingConfig(
         tasklet(jobRepository, transactionManager, monitoringTasklet)
     }
 
-    @Scheduled(cron = "1 * * * * *")
+    @Scheduled(cron = "0/10 * * * * *")
     fun dormScheduling() {
         val param = JobParametersBuilder()
             .addDate("date", Date())

web/batch-server/src/main/kotlin/com/knet/batch/config/MonitoringTasklet.kt

@@ -49,7 +49,7 @@ class MonitoringTasklet(
         noticeService.createNoticeAll(notices)
         try {
             runBlocking(Dispatchers.IO) {
-                withTimeout(2000L) {
+
                     val deferreds = mutableListOf<Deferred<Unit>>()
                     notices.forEach { notice ->
                         val deferred = async {
@@ -64,7 +64,7 @@ class MonitoringTasklet(
                     }
                     for (deferred in deferreds) deferred.await()
                 }
-            }
+
         } catch (e: Exception) {
             logger.error("send message error : ${e.message}")
         }