fix: DeadLetterEventPublisher가 TraceId를 세팅하도록 수정한다

Author: devxb

src/main/kotlin/org/gitanimals/supports/deadletter/DeadLetterEventPublisher.kt

@@ -1,20 +1,28 @@
 package org.gitanimals.supports.deadletter
 
+import org.gitanimals.core.IdGenerator
+import org.gitanimals.core.filter.MDCFilter.Companion.TRACE_ID
 import org.rooftop.netx.api.SagaEvent
 import org.rooftop.netx.spi.DeadLetterListener
+import org.slf4j.MDC
 import org.springframework.context.ApplicationEventPublisher
 
 class DeadLetterEventPublisher(
     private val applicationEventPublisher: ApplicationEventPublisher,
 ) : DeadLetterListener {
 
     override fun listen(deadLetterId: String, sagaEvent: SagaEvent) {
-        applicationEventPublisher.publishEvent(
-            DeadLetterEvent(
-                deadLetterId = deadLetterId,
-                sagaEvent = sagaEvent,
+        runCatching {
+            MDC.put(TRACE_ID, IdGenerator.generate().toString())
+            applicationEventPublisher.publishEvent(
+                DeadLetterEvent(
+                    deadLetterId = deadLetterId,
+                    sagaEvent = sagaEvent,
+                )
             )
-        )
+        }.also {
+            MDC.remove(TRACE_ID)
+        }
     }
 }
 

src/main/kotlin/org/gitanimals/supports/deadletter/DeadLetterTestController.kt

@@ -1,5 +1,7 @@
 package org.gitanimals.supports.deadletter
 
+import org.gitanimals.core.TraceIdContextOrchestrator
+import org.gitanimals.core.TraceIdContextRollback
 import org.rooftop.netx.api.OrchestratorFactory
 import org.springframework.web.bind.annotation.GetMapping
 import org.springframework.web.bind.annotation.RequestParam
@@ -17,21 +19,25 @@ class DeadLetterTestController(
     ) {
         val orchestrator = orchestratorFactory.create<String>("dead-letter-test")
             .startWithContext(
-                contextOrchestrate = { _, it -> it },
-                contextRollback = { _, it ->
+                contextOrchestrate = TraceIdContextOrchestrator { _, it -> it },
+                contextRollback = TraceIdContextRollback { _, it ->
                     it
                 }
             )
             .joinWithContext(
-                contextOrchestrate = { _, it -> it },
-                contextRollback = { _, it ->
+                contextOrchestrate = TraceIdContextOrchestrator { _, it -> it },
+                contextRollback = TraceIdContextRollback { _, it ->
                     throw IllegalStateException("add dead letter")
                 }
             )
-            .commitWithContext { _, _ ->
+            .commitWithContext(TraceIdContextOrchestrator { _, _ ->
                 throw IllegalStateException("test dead-letter")
-            }
+            })
 
-        orchestrator.sagaSync(message, context = mapOf("hello" to "world"))
+        val result = orchestrator.sagaSync(message, context = mapOf("hello" to "world"))
+
+        if (result.isSuccess.not()) {
+            result.throwError()
+        }
     }
 }