Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix breaking changes from Micrometer Tracing snapshot

Browse Source
This commit is contained in:
Chris Bono
2022-10-03 16:05:26 -05:00
committed by Chris Bono
parent 04846acb95
commit 7c7b150b83
2 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
spring-pulsar/src/main/java/org/springframework/pulsar/core/PulsarTemplate.java
View File

@@ -216,7 +216,7 @@ public class PulsarTemplate<T>
}
else {
observation = PulsarTemplateObservation.TEMPLATE_OBSERVATION.observation(this.observationConvention,
DefaultPulsarTemplateObservationConvention.INSTANCE, senderContext, this.observationRegistry);
DefaultPulsarTemplateObservationConvention.INSTANCE, () -> senderContext, this.observationRegistry);
}
return observation;
}

2
spring-pulsar/src/main/java/org/springframework/pulsar/listener/DefaultPulsarMessageListenerContainer.java
View File

@@ -369,7 +369,7 @@ public class DefaultPulsarMessageListenerContainer<T> extends AbstractPulsarMess
observation = PulsarListenerObservation.LISTENER_OBSERVATION.observation(
this.containerProperties.getObservationConvention(),
DefaultPulsarListenerObservationConvention.INSTANCE,
new PulsarMessageReceiverContext(message, getBeanName()),
() -> new PulsarMessageReceiverContext(message, getBeanName()),
this.observationRegistry);
}
observation.observe(() -> {