refactor: CRM_LISTENER_POOL 할당

belljun3395 · Jan 14, 2025 · 1e2c4ae · 1e2c4ae
1 parent e23043a
commit 1e2c4ae
Show file tree

Hide file tree

Showing 4 changed files with 8 additions and 4 deletions.
diff --git a/domain/crm/src/main/kotlin/com/few/crm/email/event/schedule/ScheduledEventListener.kt b/domain/crm/src/main/kotlin/com/few/crm/email/event/schedule/ScheduledEventListener.kt
@@ -1,5 +1,6 @@
 package com.few.crm.email.event.schedule
 
+import com.few.crm.config.CrmThreadPoolConfig.Companion.CRM_LISTENER_POOL
 import com.few.crm.email.event.schedule.handler.CancelScheduledEventHandler
 import com.few.crm.support.jpa.CrmTransactional
 import org.springframework.context.event.EventListener
@@ -11,7 +12,7 @@ import org.springframework.transaction.annotation.Propagation
 class ScheduledEventListener(
     private val cancelScheduledEventHandler: CancelScheduledEventHandler,
 ) {
-    @Async
+    @Async(CRM_LISTENER_POOL)
     @EventListener
     @CrmTransactional(propagation = Propagation.REQUIRES_NEW)
     fun onCancelEvent(event: CancelScheduledEvent) {

diff --git a/domain/crm/src/main/kotlin/com/few/crm/email/event/send/EmailSendEventListener.kt b/domain/crm/src/main/kotlin/com/few/crm/email/event/send/EmailSendEventListener.kt
@@ -1,5 +1,6 @@
 package com.few.crm.email.event.send
 
+import com.few.crm.config.CrmThreadPoolConfig.Companion.CRM_LISTENER_POOL
 import com.few.crm.email.event.send.handler.*
 import com.few.crm.email.relay.send.EmailSendEventMessageMapper
 import com.few.crm.support.jpa.CrmTransactional
@@ -18,7 +19,7 @@ class EmailSendEventListener(
     private val emailDeliveryDelayEventHandler: EmailDeliveryDelayEventHandler,
     private val emailSendEventMessageMapper: EmailSendEventMessageMapper,
 ) {
-    @Async
+    @Async(CRM_LISTENER_POOL)
     @EventListener
     @CrmTransactional(propagation = Propagation.REQUIRES_NEW)
     fun onEvent(event: EmailSendEvent) {

diff --git a/...src/main/kotlin/com/few/crm/email/event/send/NotificationEmailSendTimeOutEventListener.kt b/...src/main/kotlin/com/few/crm/email/event/send/NotificationEmailSendTimeOutEventListener.kt
@@ -1,5 +1,6 @@
 package com.few.crm.email.event.send
 
+import com.few.crm.config.CrmThreadPoolConfig.Companion.CRM_LISTENER_POOL
 import com.few.crm.email.event.send.handler.NotificationEmailSendTimeOutEventHandler
 import com.few.crm.email.event.send.handler.NotificationEmailSendTimeOutInvokeEventHandler
 import com.few.crm.support.jpa.CrmTransactional
@@ -13,7 +14,7 @@ class NotificationEmailSendTimeOutEventListener(
     private val notificationEmailSendTimeOutEventHandler: NotificationEmailSendTimeOutEventHandler,
     private val notificationEmailSendTimeOutInvokeEventHandler: NotificationEmailSendTimeOutInvokeEventHandler,
 ) {
-    @Async
+    @Async(CRM_LISTENER_POOL)
     @EventListener
     @CrmTransactional(propagation = Propagation.REQUIRES_NEW)
     fun onEvent(event: NotificationEmailSendTimeOutEvent) {

diff --git a/.../crm/src/main/kotlin/com/few/crm/email/event/template/EventTemplateTransactionListener.kt b/.../crm/src/main/kotlin/com/few/crm/email/event/template/EventTemplateTransactionListener.kt
@@ -1,5 +1,6 @@
 package com.few.crm.email.event.template
 
+import com.few.crm.config.CrmThreadPoolConfig.Companion.CRM_LISTENER_POOL
 import com.few.crm.email.event.template.handler.PostEmailTemplateEventHandler
 import com.few.crm.support.jpa.CrmTransactional
 import org.springframework.scheduling.annotation.Async
@@ -12,7 +13,7 @@ import org.springframework.transaction.event.TransactionalEventListener
 class EventTemplateTransactionListener(
     private val postEmailTemplateEventHandler: PostEmailTemplateEventHandler,
 ) {
-    @Async
+    @Async(CRM_LISTENER_POOL)
     @CrmTransactional(propagation = Propagation.REQUIRES_NEW)
     @TransactionalEventListener(phase = TransactionPhase.AFTER_COMPLETION)
     fun handleAfterCompletionEvent(event: EmailTemplateTransactionAfterCompletionEvent) {