Bumping versions
This commit is contained in:
4
pom.xml
4
pom.xml
@@ -29,7 +29,7 @@
|
||||
<parent>
|
||||
<groupId>org.springframework.cloud</groupId>
|
||||
<artifactId>spring-cloud-build</artifactId>
|
||||
<version>3.0.2</version>
|
||||
<version>3.0.3-SNAPSHOT</version>
|
||||
<relativePath/>
|
||||
<!-- lookup parent from repository -->
|
||||
</parent>
|
||||
@@ -62,7 +62,7 @@
|
||||
<maven.compiler.source>1.8</maven.compiler.source>
|
||||
<maven.compiler.testTarget>1.8</maven.compiler.testTarget>
|
||||
<maven.compiler.testSource>1.8</maven.compiler.testSource>
|
||||
<spring-cloud-build.version>3.0.2</spring-cloud-build.version>
|
||||
<spring-cloud-build.version>3.0.3-SNAPSHOT</spring-cloud-build.version>
|
||||
<spring-cloud-commons.version>3.0.3-SNAPSHOT</spring-cloud-commons.version>
|
||||
<spring-cloud-gateway.version>3.0.3-SNAPSHOT</spring-cloud-gateway.version>
|
||||
<spring-cloud-circuitbreaker.version>2.0.2-SNAPSHOT</spring-cloud-circuitbreaker.version>
|
||||
|
||||
@@ -22,7 +22,7 @@
|
||||
<parent>
|
||||
<artifactId>spring-cloud-dependencies-parent</artifactId>
|
||||
<groupId>org.springframework.cloud</groupId>
|
||||
<version>3.0.3-SNAPSHOT</version>
|
||||
<version>3.0.2</version>
|
||||
<relativePath/>
|
||||
</parent>
|
||||
<artifactId>spring-cloud-sleuth-dependencies</artifactId>
|
||||
|
||||
@@ -114,4 +114,5 @@ public class MessageHeaderPropagatorGetter implements Propagator.Getter<MessageH
|
||||
public String toString() {
|
||||
return "MessageHeaderPropagatorGetter{}";
|
||||
}
|
||||
|
||||
}
|
||||
|
||||
@@ -63,9 +63,11 @@ public class MultipleHopsIntegrationTests
|
||||
// baz is not tagged in the initial span, only downstream!
|
||||
then(this.application.allSpans()).as("All downstream have country-code")
|
||||
.filteredOn(span -> !span.equals(initialSpan))
|
||||
// it propagates only and all the `spring.sleuth.baggage.remote-fields` in case insensitive way
|
||||
// it propagates only and all the `spring.sleuth.baggage.remote-fields` in
|
||||
// case insensitive way
|
||||
.allMatch(span -> "FO".equals(COUNTRY_CODE.getValue(BraveAccessor.traceContext(span.context()))))
|
||||
.allMatch(span -> "123".equalsIgnoreCase(CASE_INSENSITIVE_ID.getValue(BraveAccessor.traceContext(span.context()))))
|
||||
.allMatch(span -> "123"
|
||||
.equalsIgnoreCase(CASE_INSENSITIVE_ID.getValue(BraveAccessor.traceContext(span.context()))))
|
||||
.allMatch(span -> NOT_PROPAGATED_HEADER.getValue(BraveAccessor.traceContext(span.context())) == null);
|
||||
}
|
||||
|
||||
|
||||
@@ -48,15 +48,11 @@ public class TracingChannelInterceptorTest
|
||||
this.testTracing = new BraveTestTracing() {
|
||||
@Override
|
||||
public Tracing.Builder tracingBuilder() {
|
||||
return super.tracingBuilder()
|
||||
.propagationFactory(BaggagePropagation.newFactoryBuilder(B3Propagation.newFactoryBuilder()
|
||||
.injectFormat(SINGLE)
|
||||
.build()
|
||||
)
|
||||
.add(BaggagePropagationConfig.SingleBaggageField.remote(BaggageField.create("Foo-Id")))
|
||||
.add(BaggagePropagationConfig.SingleBaggageField.remote(BaggageField.create("Baz-Id")))
|
||||
.build()
|
||||
);
|
||||
return super.tracingBuilder().propagationFactory(BaggagePropagation
|
||||
.newFactoryBuilder(B3Propagation.newFactoryBuilder().injectFormat(SINGLE).build())
|
||||
.add(BaggagePropagationConfig.SingleBaggageField.remote(BaggageField.create("Foo-Id")))
|
||||
.add(BaggagePropagationConfig.SingleBaggageField.remote(BaggageField.create("Baz-Id")))
|
||||
.build());
|
||||
}
|
||||
};
|
||||
this.testTracing.reset();
|
||||
@@ -77,7 +73,7 @@ public class TracingChannelInterceptorTest
|
||||
|
||||
TraceContext receiveContext = parseB3SingleFormat(
|
||||
((List) ((Map) this.channel.receive().getHeaders().get(NATIVE_HEADERS)).get("b3")).get(0).toString())
|
||||
.context();
|
||||
.context();
|
||||
assertThat(receiveContext.parentIdString()).isEqualTo("000000000000000b");
|
||||
}
|
||||
|
||||
|
||||
@@ -381,7 +381,8 @@ public abstract class TracingChannelInterceptorTest implements TestTracingAwareS
|
||||
Message<?> actualMessage = channel.receive();
|
||||
|
||||
assertThat(actualMessage.getHeaders()).isNotEmpty();
|
||||
LinkedMultiValueMap<String, String> actualNativeHeaders = (LinkedMultiValueMap) actualMessage.getHeaders().get(NATIVE_HEADERS);
|
||||
LinkedMultiValueMap<String, String> actualNativeHeaders = (LinkedMultiValueMap) actualMessage.getHeaders()
|
||||
.get(NATIVE_HEADERS);
|
||||
assertThat(actualNativeHeaders).isNotEmpty();
|
||||
assertThat(actualNativeHeaders.get("not-propagated-header")).isNull();
|
||||
assertThat(actualNativeHeaders.get("Foo-Id")).isEqualTo(singletonList("123"));
|
||||
|
||||
Reference in New Issue
Block a user