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 
    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
     
    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.