From 1e8538fea24ea3745d3d16023d4927cf31f8b4f5 Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Mon, 19 Sep 2022 09:10:04 +0200 Subject: [PATCH 1/2] ReceiverContext was missing a remoteServiceName --- .../transport/ReceiverContext.java | 20 +++++++++++++++++++ 1 file changed, 20 insertions(+) diff --git a/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java b/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java index 9aa6c7aecf..5a0867d3a0 100644 --- a/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java +++ b/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java @@ -36,6 +36,9 @@ public class ReceiverContext extends Observation.Context { private C carrier; + @Nullable + private String remoteServiceName; + /** * Creates a new instance of {@link ReceiverContext}. * @param getter propagator getter @@ -70,4 +73,21 @@ public Kind getKind() { return kind; } + /** + * Return optional name for the service from which the message is polled. + * @return optional name for the service from which the message is polled + */ + @Nullable + public String getRemoteServiceName() { + return remoteServiceName; + } + + /** + * Set optional name for the service from which the message is polled. + * @param remoteServiceName name of the service from which the message is polled + */ + public void setRemoteServiceName(@Nullable String remoteServiceName) { + this.remoteServiceName = remoteServiceName; + } + } From da83d4718e7b527d4fe14715cf898cecad535d9e Mon Sep 17 00:00:00 2001 From: Marcin Grzejszczak Date: Mon, 19 Sep 2022 09:29:54 +0200 Subject: [PATCH 2/2] Added missing import --- .../io/micrometer/observation/transport/ReceiverContext.java | 1 + 1 file changed, 1 insertion(+) diff --git a/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java b/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java index 5a0867d3a0..00a5c04110 100644 --- a/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java +++ b/micrometer-observation/src/main/java/io/micrometer/observation/transport/ReceiverContext.java @@ -16,6 +16,7 @@ package io.micrometer.observation.transport; import io.micrometer.common.lang.NonNull; +import io.micrometer.common.lang.Nullable; import io.micrometer.observation.Observation; import java.util.Objects;