Add BlockHound

Author: mfvanek

spring-boot-3-demo-app-kotlin/src/test/kotlin/io/github/mfvanek/spring/boot3/kotlin/test/IndexesMaintenanceTest.kt renamed to spring-boot-3-demo-app-kotlin/src/test/kotlin/io/github/mfvanek/spring/boot3/kotlin/test/DatabaseStructureStaticAnalysisTest.kt

@@ -11,7 +11,8 @@ import org.junit.jupiter.api.DisplayName
 import org.junit.jupiter.api.Test
 import org.springframework.beans.factory.annotation.Autowired
 
-class IndexesMaintenanceTest : TestBase() {
+internal class DatabaseStructureStaticAnalysisTest : TestBase() {
+
     @Autowired
     private lateinit var checks: List<DatabaseCheckOnHost<out DbObject>>
 

spring-boot-3-demo-app-reactive/build.gradle.kts

@@ -42,9 +42,14 @@ dependencies {
     testImplementation("io.github.mfvanek:pg-index-health-test-starter")
     testImplementation("org.springframework.cloud:spring-cloud-starter-contract-stub-runner")
     testImplementation("io.projectreactor:reactor-test")
+    testImplementation("io.projectreactor.tools:blockhound:1.0.13.RELEASE")
 }
 
 tasks {
+    withType<Test>().all {
+        jvmArgs("-XX:+AllowRedefinitionToAddDeleteMethods")
+    }
+
     jacocoTestCoverageVerification {
         dependsOn(jacocoTestReport)
         violationRules {

spring-boot-3-demo-app-reactive/src/main/java/io/github/mfvanek/spring/boot3/reactive/Application.java

@@ -9,11 +9,13 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import reactor.tools.agent.ReactorDebugAgent;
 
 @SpringBootApplication
 public class Application {
 
     public static void main(String[] args) {
+        ReactorDebugAgent.init();
         SpringApplication.run(Application.class, args);
     }
 }

spring-boot-3-demo-app-reactive/src/main/java/io/github/mfvanek/spring/boot3/reactive/service/KafkaSendingService.java

@@ -15,6 +15,7 @@
 import org.springframework.kafka.support.SendResult;
 import org.springframework.stereotype.Service;
 import reactor.core.publisher.Mono;
+import reactor.core.scheduler.Schedulers;
 
 import java.util.UUID;
 import javax.annotation.Nonnull;
@@ -32,7 +33,8 @@ public Mono<SendResult<UUID, String>> sendNotification(@Nonnull final String mes
         return Mono.deferContextual(contextView -> {
             try (MDC.MDCCloseable ignored = MDC.putCloseable("tenant.name", tenantName)) {
                 log.info("Sending message \"{}\" to Kafka", message);
-                return Mono.fromFuture(() -> kafkaTemplate.sendDefault(UUID.randomUUID(), message));
+                return Mono.fromFuture(() -> kafkaTemplate.sendDefault(UUID.randomUUID(), message))
+                    .subscribeOn(Schedulers.boundedElastic());
             }
         });
     }

spring-boot-3-demo-app-reactive/src/main/java/io/github/mfvanek/spring/boot3/reactive/service/PublicApiService.java

@@ -54,6 +54,7 @@ private Mono<CurrentTime> getZonedTimeFromWorldTimeApi() {
             .bodyToMono(String.class)
             .retryWhen(prepareRetry(zoneName))
             .flatMap(this::convert)
+            .doOnError(err -> log.warn("Received error response", err)) // TODO ???
             .onErrorComplete()
             .flatMap(Mono::justOrEmpty);
     }

spring-boot-3-demo-app-reactive/src/test/java/io/github/mfvanek/spring/boot3/reactive/IndexesMaintenanceTest.java renamed to spring-boot-3-demo-app-reactive/src/test/java/io/github/mfvanek/spring/boot3/reactive/DatabaseStructureStaticAnalysisTest.java

@@ -21,7 +21,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-class IndexesMaintenanceTest extends TestBase {
+class DatabaseStructureStaticAnalysisTest extends TestBase {
 
     @Autowired
     private List<DatabaseCheckOnHost<? extends DbObject>> checks;

spring-boot-3-demo-app-reactive/src/test/java/io/github/mfvanek/spring/boot3/reactive/support/TestBase.java

@@ -12,6 +12,7 @@
 import io.github.mfvanek.spring.boot3.reactive.service.dto.CurrentTime;
 import io.github.mfvanek.spring.boot3.reactive.service.dto.ParsedDateTime;
 import lombok.SneakyThrows;
+import org.junit.jupiter.api.BeforeAll;
 import org.junit.jupiter.api.BeforeEach;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.test.autoconfigure.actuate.observability.AutoConfigureObservability;
@@ -22,6 +23,7 @@
 import org.springframework.test.context.ActiveProfiles;
 import org.springframework.test.context.ContextConfiguration;
 import org.springframework.test.web.reactive.server.WebTestClient;
+import reactor.blockhound.BlockHound;
 
 import java.time.Clock;
 import java.util.TimeZone;
@@ -51,6 +53,11 @@ public abstract class TestBase {
     @Autowired
     protected NamedParameterJdbcTemplate namedParameterJdbcTemplate;
 
+    @BeforeAll
+    static void initBlockHound() {
+        BlockHound.install();
+    }
+
     @BeforeEach
     void resetExternalMocks() {
         WireMock.resetAllRequests();

spring-boot-3-demo-app/src/test/java/io/github/mfvanek/spring/boot3/test/IndexesMaintenanceTest.java renamed to spring-boot-3-demo-app/src/test/java/io/github/mfvanek/spring/boot3/test/DatabaseStructureStaticAnalysisTest.java

@@ -21,7 +21,7 @@
 
 import static org.assertj.core.api.Assertions.assertThat;
 
-class IndexesMaintenanceTest extends TestBase {
+class DatabaseStructureStaticAnalysisTest extends TestBase {
 
     @Autowired
     private List<DatabaseCheckOnHost<? extends DbObject>> checks;