@@ -28,6 +28,10 @@
|
||||
<groupId>org.springframework.cloud</groupId>
|
||||
<artifactId>spring-cloud-commons</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-aop</artifactId>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-actuator</artifactId>
|
||||
@@ -59,8 +63,8 @@
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
<dependency>
|
||||
<groupId>org.aspectj</groupId>
|
||||
<artifactId>aspectjweaver</artifactId>
|
||||
<groupId>com.jayway.awaitility</groupId>
|
||||
<artifactId>awaitility</artifactId>
|
||||
<scope>test</scope>
|
||||
</dependency>
|
||||
</dependencies>
|
||||
|
||||
@@ -57,6 +57,8 @@ import org.springframework.integration.annotation.ServiceActivator;
|
||||
import org.springframework.messaging.Message;
|
||||
import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;
|
||||
|
||||
import com.jayway.awaitility.Awaitility;
|
||||
|
||||
/**
|
||||
* @author Dave Syer
|
||||
*
|
||||
@@ -89,7 +91,7 @@ public class StreamSpanListenerTests {
|
||||
|
||||
this.tracer.close(context);
|
||||
|
||||
assertThat(this.test.spans).hasSize(1);
|
||||
Awaitility.await().until(() -> assertThat(StreamSpanListenerTests.this.test.spans).hasSize(1));
|
||||
}
|
||||
|
||||
@Test
|
||||
@@ -103,7 +105,7 @@ public class StreamSpanListenerTests {
|
||||
|
||||
this.tracer.close(context);
|
||||
|
||||
assertThat(this.test.spans).hasSize(2);
|
||||
Awaitility.await().until(() -> assertThat(StreamSpanListenerTests.this.test.spans).hasSize(2));
|
||||
}
|
||||
|
||||
void logServerReceived(Span parent) {
|
||||
|
||||
Reference in New Issue
Block a user