Merge pull request #8879 from mathieufortin01/BAEL-3806

glmartin · web-flow · commit c0f61d01678c · 2020-03-20T14:48:37.000-04:00
BAEL-3806 Fixed integration test
diff --git a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceIntegrationTest.java
@@ -52,14 +52,13 @@ public void givenFooWithNullId_whenProcessFoo_thenLogsWithDebugTrace() {
                     .map(Arrays::stream)
                     .orElse(Stream.empty());
             })
-            .map(IThrowableProxy::getMessage)
+            .map(IThrowableProxy::getClassName)
             .collect(Collectors.toList());
         assertThat(allLoggedEntries).anyMatch(entry -> entry.contains("The following error happened on processFoo method!"))
             .anyMatch(entry -> entry.contains("| onSubscribe"))
             .anyMatch(entry -> entry.contains("| cancel()"));
 
-        assertThat(allSuppressedEntries).anyMatch(entry -> entry.contains("Assembly trace from producer"))
-            .anyMatch(entry -> entry.contains("Error has been observed by the following operator(s)"));
+        assertThat(allSuppressedEntries)
+            .anyMatch(entry -> entry.contains("reactor.core.publisher.FluxOnAssembly$OnAssemblyException"));
     }
-
 }
diff --git a/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java b/spring-5-reactive-2/src/test/java/com/baeldung/debugging/consumer/ConsumerFooServiceLiveTest.java
@@ -7,6 +7,11 @@
 
 import com.baeldung.debugging.consumer.service.FooService;
 
+/**
+ * In order to run this live test, start the following classes:
+ * - com.baeldung.debugging.server.ServerDebuggingApplication
+ * - com.baeldung.debugging.consumer.ConsumerDebuggingApplication
+ */
 public class ConsumerFooServiceLiveTest {
 
     FooService service = new FooService();
