Package org.springframework.rabbit.stream.micrometer

Class RabbitStreamMessageReceiverContext

java.lang.Object

io.micrometer.observation.Observation.Context

io.micrometer.observation.transport.ReceiverContext<com.rabbitmq.stream.Message>

org.springframework.rabbit.stream.micrometer.RabbitStreamMessageReceiverContext

All Implemented Interfaces:

io.micrometer.observation.Observation.ContextView

public class RabbitStreamMessageReceiverContext
extends io.micrometer.observation.transport.ReceiverContext<com.rabbitmq.stream.Message>

ReceiverContext for stream Messages.

Since:

3.0.5

Author:

Gary Russell

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	RabbitStreamMessageReceiverContext.DefaultRabbitListenerObservationConvention	Default RabbitListenerObservationConvention for Rabbit listener key values.

Constructor Summary

Constructors

Constructor	Description
RabbitStreamMessageReceiverContext(com.rabbitmq.stream.Message message, String listenerId, String stream)

Method Summary

Modifier and Type	Method	Description
String	getListenerId()
String	getSource()	Return the source (stream) for this message.

Methods inherited from class io.micrometer.observation.transport.ReceiverContext

getCarrier, getGetter, getKind, getRemoteServiceAddress, getRemoteServiceName, setCarrier, setRemoteServiceAddress, setRemoteServiceName

Methods inherited from class io.micrometer.observation.Observation.Context

addHighCardinalityKeyValue, addHighCardinalityKeyValues, addLowCardinalityKeyValue, addLowCardinalityKeyValues, clear, computeIfAbsent, containsKey, get, getAllKeyValues, getContextualName, getError, getHighCardinalityKeyValue, getHighCardinalityKeyValues, getLowCardinalityKeyValue, getLowCardinalityKeyValues, getName, getOrDefault, getParentObservation, getRequired, put, remove, removeHighCardinalityKeyValue, removeHighCardinalityKeyValues, removeLowCardinalityKeyValue, removeLowCardinalityKeyValues, setContextualName, setError, setName, setParentObservation, toString

Methods inherited from class java.lang.Object

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

Constructor Details

RabbitStreamMessageReceiverContext

public RabbitStreamMessageReceiverContext(com.rabbitmq.stream.Message message,
 String listenerId,
 String stream)

Method Details

getListenerId

public String getListenerId()

getSource

public String getSource()

Return the source (stream) for this message.

Returns:

the source.