diff --git a/spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapter.java b/spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapter.java index a36e4d11d229..6466202b8a0e 100644 --- a/spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapter.java +++ b/spring-boot-project/spring-boot-actuator-autoconfigure/src/main/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapter.java @@ -56,16 +56,16 @@ public boolean supportsContext(Observation.Context context) { @Override public KeyValues getLowCardinalityKeyValues(ClientRequestObservationContext context) { mutateClientRequest(context); - Iterable tags = this.tagsProvider.tags(context.getCarrier(), context.getResponse(), context.getError()); + Iterable tags = this.tagsProvider.tags(context.getRequest(), context.getResponse(), context.getError()); return KeyValues.of(tags, Tag::getKey, Tag::getValue); } private void mutateClientRequest(ClientRequestObservationContext context) { // WebClientExchangeTagsProvider relies on a request attribute to get the URI // template, we need to adapt to that. - ClientRequest clientRequest = ClientRequest.from(context.getCarrier()) + ClientRequest clientRequest = ClientRequest.from(context.getRequest()) .attribute(URI_TEMPLATE_ATTRIBUTE, context.getUriTemplate()).build(); - context.setCarrier(clientRequest); + context.setRequest(clientRequest); } @Override diff --git a/spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapterTests.java b/spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapterTests.java index 590eac537883..6740fd4154ae 100644 --- a/spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapterTests.java +++ b/spring-boot-project/spring-boot-actuator-autoconfigure/src/test/java/org/springframework/boot/actuate/autoconfigure/observation/web/client/ClientObservationConventionAdapterTests.java @@ -45,7 +45,7 @@ class ClientObservationConventionAdapterTests { private ClientObservationConventionAdapter convention = new ClientObservationConventionAdapter(TEST_METRIC_NAME, new DefaultWebClientExchangeTagsProvider()); - private ClientRequest request = ClientRequest.create(HttpMethod.GET, URI.create("/resource/test")).build(); + private ClientRequest.Builder requestBuilder = ClientRequest.create(HttpMethod.GET, URI.create("/resource/test")); private ClientResponse response = ClientResponse.create(HttpStatus.OK).body("foo").build(); @@ -54,7 +54,8 @@ class ClientObservationConventionAdapterTests { @BeforeEach void setup() { this.context = new ClientRequestObservationContext(); - this.context.setCarrier(this.request); + this.context.setCarrier(this.requestBuilder); + this.context.setRequest(this.requestBuilder.build()); this.context.setResponse(this.response); this.context.setUriTemplate("/resource/{name}"); }