Enhance error detection in complex Flux Flows

dbuos · Daniel Bustamante Ospina · commit a086510faaf3 · 2020-07-20T13:32:45.000-05:00
diff --git a/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/GenericMessageListener.java b/async/async-commons/src/main/java/org/reactivecommons/async/impl/listeners/GenericMessageListener.java
@@ -112,6 +112,8 @@ private <T> Flux<T> outerFailureProtection(Flux<T> messageFlux) {
                 } catch (Exception e) {
                     log.log(Level.SEVERE, "Error returning message in failure!", e);
                 }
+            } else {
+                throw new RuntimeException(throwable);
             }
         });
     }
diff --git a/gradle.properties b/gradle.properties
@@ -1,3 +1,3 @@
-version=0.5.0
-springBootVersion=2.2.6.RELEASE
+version=0.5.2-beta
+springBootVersion=2.2.8.RELEASE
 gradleVersionsVersion=0.28.0

Original file line number	Diff line number	Diff line change
`@@ -112,6 +112,8 @@ private <T> Flux<T> outerFailureProtection(Flux<T> messageFlux) {`
`112`	`112`	`} catch (Exception e) {`
`113`	`113`	`log.log(Level.SEVERE, "Error returning message in failure!", e);`
`114`	`114`	`}`
	`115`	`+ } else {`
	`116`	`+ throw new RuntimeException(throwable);`
`115`	`117`	`}`
`116`	`118`	`});`
`117`	`119`	`}`