SpringCloud/spring-cloud-sleuth
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

And now?

Browse Source
This commit is contained in:
Marcin Grzejszczak
2018-10-11 13:18:11 +02:00
parent a34b82f47f
commit f3f7e47294
1 changed files with 6 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
spring-cloud-sleuth-core/src/test/java/org/springframework/cloud/sleuth/annotation/SleuthSpanCreatorAspectWebFluxTests.java
View File

@@ -61,20 +61,24 @@ import static org.assertj.core.api.BDDAssertions.then;
@RunWith(SpringRunner.class)
@SpringBootTest(properties = { "spring.main.web-application-type=reactive" }, classes = {
SleuthSpanCreatorAspectWebFluxTests.TestEndpoint.class,
SleuthSpanCreatorAspectWebFluxTests.TestConfiguration.class },
webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
SleuthSpanCreatorAspectWebFluxTests.TestConfiguration.class }, webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)
@DirtiesContext
public class SleuthSpanCreatorAspectWebFluxTests {
private static final Log log = LogFactory
.getLog(SleuthSpanCreatorAspectWebFluxTests.class);
@Autowired
Tracer tracer;
@Autowired
AccessLoggingHttpTraceRepository repository;
@Autowired
ArrayListSpanReporter reporter;
private WebTestClient webClient;
@LocalServerPort
private int port;
@@ -105,8 +109,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/ping").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {
@@ -131,8 +133,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/pingFromContext").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {
@@ -151,8 +151,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/continueSpan").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {
@@ -170,8 +168,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/newSpan1").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {
@@ -190,8 +186,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/newSpan2").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {
@@ -212,8 +206,6 @@ public class SleuthSpanCreatorAspectWebFluxTests {
Mono<Long> mono = webClient.get().uri("/test/ping").exchange()
.returnResult(Long.class).getResponseBody().single();
then(this.reporter.getSpans()).isEmpty();
Long newSpanId = mono.block();
Awaitility.await().untilAsserted(() -> {