File tree Expand file tree Collapse file tree 1 file changed +5
-0
lines changed
src/main/kotlin/org/gitanimals/supports/deadletter Expand file tree Collapse file tree 1 file changed +5
-0
lines changed Original file line number Diff line number Diff line change @@ -4,13 +4,16 @@ import org.gitanimals.core.IdGenerator
44import org.gitanimals.core.filter.MDCFilter.Companion.TRACE_ID
55import org.rooftop.netx.api.SagaEvent
66import org.rooftop.netx.spi.DeadLetterListener
7+ import org.slf4j.LoggerFactory
78import org.slf4j.MDC
89import org.springframework.context.ApplicationEventPublisher
910
1011class DeadLetterEventPublisher (
1112 private val applicationEventPublisher : ApplicationEventPublisher ,
1213) : DeadLetterListener {
1314
15+ private val logger = LoggerFactory .getLogger(this ::class .simpleName)
16+
1417 override fun listen (deadLetterId : String , sagaEvent : SagaEvent ) {
1518 runCatching {
1619 MDC .put(TRACE_ID , IdGenerator .generate().toString())
@@ -23,6 +26,8 @@ class DeadLetterEventPublisher(
2326 deadLetter = sagaEvent.decodeEvent(String ::class ),
2427 )
2528 )
29+ }.onFailure {
30+ logger.error(" Fail to publish dead letter event deadLetterId: \" $deadLetterId \" , event: \" $sagaEvent \" " , it)
2631 }.also {
2732 MDC .remove(TRACE_ID )
2833 }
You can’t perform that action at this time.
0 commit comments