Bumping versions
This commit is contained in:
@@ -86,7 +86,7 @@ Please visit the https://docs.spring.io/spring-cloud-sleuth/docs/[documentation
|
||||
|
||||
== Building
|
||||
|
||||
:jdkversion: 1.7
|
||||
:jdkversion: 1.8
|
||||
|
||||
=== Basic Compile and Test
|
||||
|
||||
|
||||
@@ -28,7 +28,7 @@
|
||||
<parent>
|
||||
<groupId>org.springframework.boot</groupId>
|
||||
<artifactId>spring-boot-starter-parent</artifactId>
|
||||
<version>2.4.0</version>
|
||||
<version>2.4.1</version>
|
||||
<relativePath/> <!-- lookup parent from repository -->
|
||||
</parent>
|
||||
|
||||
|
||||
@@ -95,9 +95,11 @@ class W3CPropagationTest {
|
||||
@Test
|
||||
void inject_traceIdShouldBePaddedWithZeros() {
|
||||
Map<String, String> carrier = new LinkedHashMap<>();
|
||||
TraceContext traceContext = sampledTraceContext("0000000000000000", "123456789abcdef0", "123456789abcdef1").build();
|
||||
TraceContext traceContext = sampledTraceContext("0000000000000000", "123456789abcdef0", "123456789abcdef1")
|
||||
.build();
|
||||
w3CPropagation.injector((ignored, key, value) -> carrier.put(key, value)).inject(traceContext, carrier);
|
||||
assertThat(carrier).containsExactly(entry(TRACE_PARENT, "00-0000000000000000123456789abcdef0-123456789abcdef1-01"));
|
||||
assertThat(carrier)
|
||||
.containsExactly(entry(TRACE_PARENT, "00-0000000000000000123456789abcdef0-123456789abcdef1-01"));
|
||||
}
|
||||
|
||||
@Test
|
||||
|
||||
@@ -42,16 +42,20 @@ public abstract class TraceWebSocketAutoConfigurationTests {
|
||||
@Test
|
||||
public void should_register_interceptors_for_all_channels() {
|
||||
AbstractSubscribableChannel inboundChannel = this.delegatingWebSocketMessageBrokerConfiguration
|
||||
.clientInboundChannel(this.delegatingWebSocketMessageBrokerConfiguration.clientInboundChannelExecutor());
|
||||
.clientInboundChannel(
|
||||
this.delegatingWebSocketMessageBrokerConfiguration.clientInboundChannelExecutor());
|
||||
BDDAssertions.then(inboundChannel.getInterceptors())
|
||||
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
|
||||
AbstractSubscribableChannel outboundChannel = this.delegatingWebSocketMessageBrokerConfiguration
|
||||
.clientOutboundChannel(this.delegatingWebSocketMessageBrokerConfiguration.clientOutboundChannelExecutor());
|
||||
.clientOutboundChannel(
|
||||
this.delegatingWebSocketMessageBrokerConfiguration.clientOutboundChannelExecutor());
|
||||
BDDAssertions.then(outboundChannel.getInterceptors())
|
||||
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
|
||||
BDDAssertions.then(this.delegatingWebSocketMessageBrokerConfiguration
|
||||
.brokerChannel(inboundChannel, outboundChannel, this.delegatingWebSocketMessageBrokerConfiguration.brokerChannelExecutor(inboundChannel, outboundChannel))
|
||||
.getInterceptors())
|
||||
BDDAssertions
|
||||
.then(this.delegatingWebSocketMessageBrokerConfiguration.brokerChannel(inboundChannel, outboundChannel,
|
||||
this.delegatingWebSocketMessageBrokerConfiguration.brokerChannelExecutor(inboundChannel,
|
||||
outboundChannel))
|
||||
.getInterceptors())
|
||||
.hasAtLeastOneElementOfType(TracingChannelInterceptor.class);
|
||||
}
|
||||
|
||||
|
||||
Reference in New Issue
Block a user