fix: Choreographys successWith published when receive other event (#118)

* fix: Choreography's successWith published when receive orchestrate event

* docs: Netx version 0.3.7 to 0.3.8

Author: devxb

README.md

@@ -6,7 +6,7 @@
 
 <br>
 
-![version 0.3.7](https://img.shields.io/badge/version-0.3.7-black?labelColor=black&style=flat-square) ![jdk 17](https://img.shields.io/badge/minimum_jdk-17-orange?labelColor=black&style=flat-square) ![load-test](https://img.shields.io/badge/load%20test%2010%2C000%2C000-success-brightgreen?labelColor=black&style=flat-square)    
+![version 0.3.8](https://img.shields.io/badge/version-0.3.8-black?labelColor=black&style=flat-square) ![jdk 17](https://img.shields.io/badge/minimum_jdk-17-orange?labelColor=black&style=flat-square) ![load-test](https://img.shields.io/badge/load%20test%2010%2C000%2C000-success-brightgreen?labelColor=black&style=flat-square)    
 ![redis--stream](https://img.shields.io/badge/-redis--stream-da2020?style=flat-square&logo=Redis&logoColor=white)
 
 Redis-Stream을 지원하는 Saga frame work 입니다.   

gradle.properties

@@ -2,7 +2,7 @@ kotlin.code.style=official
 
 ### Project ###
 group=org.rooftop.netx
-version=0.3.2
+version=0.3.8
 compatibility=17
 
 ### Sonarcloud ###

src/main/kotlin/org/rooftop/netx/api/TransactionCommitEvent.kt

@@ -8,6 +8,6 @@ class TransactionCommitEvent internal constructor(
     codec: Codec,
 ): TransactionEvent(transactionId, nodeName, group, event, codec) {
 
-    override fun copy(): TransactionEvent =
-        TransactionJoinEvent(transactionId, nodeName, group, event, codec)
+    override fun copy(): TransactionCommitEvent =
+        TransactionCommitEvent(transactionId, nodeName, group, event, codec)
 }

src/main/kotlin/org/rooftop/netx/api/TransactionJoinEvent.kt

@@ -8,6 +8,6 @@ class TransactionJoinEvent internal constructor(
     codec: Codec,
 ) : TransactionEvent(transactionId, nodeName, group, event, codec) {
 
-    override fun copy(): TransactionEvent =
+    override fun copy(): TransactionJoinEvent =
         TransactionJoinEvent(transactionId, nodeName, group, event, codec)
 }

src/main/kotlin/org/rooftop/netx/api/TransactionRollbackEvent.kt

@@ -9,6 +9,6 @@ class TransactionRollbackEvent internal constructor(
     codec: Codec,
 ) : TransactionEvent(transactionId, nodeName, group, event, codec) {
 
-    override fun copy(): TransactionEvent =
-        TransactionJoinEvent(transactionId, nodeName, group, event, codec)
+    override fun copy(): TransactionRollbackEvent =
+        TransactionRollbackEvent(transactionId, nodeName, group, event, cause, codec)
 }

src/main/kotlin/org/rooftop/netx/api/TransactionStartEvent.kt

@@ -8,6 +8,6 @@ class TransactionStartEvent internal constructor(
     codec: Codec,
 ) : TransactionEvent(transactionId, nodeName, group, event, codec) {
 
-    override fun copy(): TransactionEvent =
-        TransactionJoinEvent(transactionId, nodeName, group, event, codec)
+    override fun copy(): TransactionStartEvent =
+        TransactionStartEvent(transactionId, nodeName, group, event, codec)
 }

src/main/kotlin/org/rooftop/netx/engine/MonoDispatchFunction.kt

@@ -36,7 +36,11 @@ internal class MonoDispatchFunction(
             .flatMap { function.call(handler, transactionEvent) }
             .info("Call Mono TransactionHandler \"${name()}\" with transactionId \"${transactionEvent.transactionId}\"")
             .switchIfEmpty(`continue`)
-            .doOnNext { publishNextTransaction(transactionEvent) }
+            .doOnNext {
+                if (isProcessable(transactionEvent)) {
+                    publishNextTransaction(transactionEvent)
+                }
+            }
             .onErrorResume {
                 if (isNoRollbackFor(it)) {
                     return@onErrorResume noRollbackFor