Package org.springframework.pulsar.observation

Class DefaultPulsarListenerObservationConvention

java.lang.Object

org.springframework.pulsar.observation.DefaultPulsarListenerObservationConvention

All Implemented Interfaces:

io.micrometer.observation.KeyValuesConvention, io.micrometer.observation.ObservationConvention<PulsarMessageReceiverContext>, PulsarListenerObservationConvention

public class DefaultPulsarListenerObservationConvention
extends Object
implements PulsarListenerObservationConvention

Default PulsarListenerObservationConvention for Pulsar listener key values.

Author:

Chris Bono

Field Summary

Fields

Modifier and Type	Field	Description
static final DefaultPulsarListenerObservationConvention	INSTANCE	A singleton instance of the convention.

Fields inherited from interface io.micrometer.observation.ObservationConvention

EMPTY

Constructor Summary

Constructors

Constructor	Description
DefaultPulsarListenerObservationConvention()

Method Summary

Modifier and Type	Method	Description
String	getContextualName(PulsarMessageReceiverContext context)
io.micrometer.common.KeyValues	getLowCardinalityKeyValues(PulsarMessageReceiverContext context)
String	getName()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface io.micrometer.observation.ObservationConvention

getHighCardinalityKeyValues

Methods inherited from interface org.springframework.pulsar.observation.PulsarListenerObservationConvention

supportsContext

Field Details

INSTANCE

public static final DefaultPulsarListenerObservationConvention INSTANCE

A singleton instance of the convention.

Constructor Details

DefaultPulsarListenerObservationConvention

public DefaultPulsarListenerObservationConvention()

Method Details

getLowCardinalityKeyValues

public io.micrometer.common.KeyValues getLowCardinalityKeyValues(PulsarMessageReceiverContext context)

Specified by:

getLowCardinalityKeyValues in interface io.micrometer.observation.ObservationConvention<PulsarMessageReceiverContext>

getName

public String getName()

Specified by:

getName in interface io.micrometer.observation.ObservationConvention<PulsarMessageReceiverContext>

Specified by:

getName in interface PulsarListenerObservationConvention

getContextualName

public String getContextualName(PulsarMessageReceiverContext context)

Specified by:

getContextualName in interface io.micrometer.observation.ObservationConvention<PulsarMessageReceiverContext>