release: 1.4.0 (#150)

Author: devxb

src/main/kotlin/org/gitanimals/notification/app/event/DeadLetterEvent.kt

@@ -6,5 +6,5 @@ data class DeadLetterEvent(
     val sagaId: String,
     val nodeName: String,
     val group: String,
-    val deadLetter: String,
+    val deadLetter: Map<String, Any>,
 )

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

@@ -11,7 +11,7 @@ data class DeadLetterEvent(
     val sagaId: String,
     val nodeName: String,
     val group: String,
-    val deadLetter: String,
+    val deadLetter: Map<String, Any>,
 ) : AsyncRedisPubSubEvent(
     traceId = runCatching { MDC.get(MDCFilter.TRACE_ID) }
         .getOrElse { IdGenerator.generate().toString() },

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

@@ -3,6 +3,7 @@ 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.api.TypeReference
 import org.rooftop.netx.spi.DeadLetterListener
 import org.slf4j.LoggerFactory
 import org.slf4j.MDC
@@ -23,7 +24,7 @@ class DeadLetterEventPublisher(
                     sagaId = sagaEvent.id,
                     group = sagaEvent.group,
                     nodeName = sagaEvent.nodeName,
-                    deadLetter = sagaEvent.decodeEvent(String::class),
+                    deadLetter = sagaEvent.decodeEvent(object: TypeReference<Map<String, Any>>(){}),
                 )
             )
         }.onFailure {