diff --git a/instrumentation/spring/spring-webflux-5.0/javaagent/build.gradle.kts b/instrumentation/spring/spring-webflux-5.0/javaagent/build.gradle.kts index f5a14df513a2..986ebd81c6ba 100644 --- a/instrumentation/spring/spring-webflux-5.0/javaagent/build.gradle.kts +++ b/instrumentation/spring/spring-webflux-5.0/javaagent/build.gradle.kts @@ -52,9 +52,9 @@ dependencies { testCompileOnly("io.projectreactor.ipc:reactor-netty:0.7.0.RELEASE") testCompileOnly("io.projectreactor.netty:reactor-netty-http:1.0.7") - testLibrary("org.springframework.boot:spring-boot-starter-webflux:2.0.0.RELEASE") - testLibrary("org.springframework.boot:spring-boot-starter-test:2.0.0.RELEASE") - testLibrary("org.springframework.boot:spring-boot-starter-reactor-netty:2.0.0.RELEASE") + testLibrary("org.springframework.boot:spring-boot-starter-webflux:2.5.0") + testLibrary("org.springframework.boot:spring-boot-starter-test:2.5.0") + testLibrary("org.springframework.boot:spring-boot-starter-reactor-netty:2.5.0") testImplementation("org.spockframework:spock-spring:1.1-groovy-2.4") } @@ -68,5 +68,8 @@ tasks.withType().configureEach { // a good approach. Come up with a better one and enable this. jvmArgs("-Dio.opentelemetry.javaagent.shaded.io.opentelemetry.context.enableStrictContext=false") +// jvmArgs("-Xint") +// jvmArgs("-Dio.netty.defaultPromise.maxListenerStackDepth=1") + systemProperty("testLatestDeps", findProperty("testLatestDeps") as Boolean) } diff --git a/instrumentation/spring/spring-webflux-5.0/javaagent/src/test/groovy/SpringWebfluxTest.groovy b/instrumentation/spring/spring-webflux-5.0/javaagent/src/test/groovy/SpringWebfluxTest.groovy index a0d22dc5eef0..f8da42f727de 100644 --- a/instrumentation/spring/spring-webflux-5.0/javaagent/src/test/groovy/SpringWebfluxTest.groovy +++ b/instrumentation/spring/spring-webflux-5.0/javaagent/src/test/groovy/SpringWebfluxTest.groovy @@ -487,7 +487,7 @@ class SpringWebfluxTest extends AgentInstrumentationSpecification { @Unroll def "Multiple GETs to delaying route #testName"() { setup: - def requestsCount = 50 // Should be more than 2x CPUs to fish out some bugs + def requestsCount = 300 // Should be more than 2x CPUs to fish out some bugs def url = "http://localhost:$port$urlPath" when: def responses = (0..requestsCount - 1).collect { client.get(urlPath).aggregate().join() }