Package com.rabbitmq.client.amqp.observation.micrometer

Class PublishContext

java.lang.Object
io.micrometer.observation.Observation.Context
io.micrometer.observation.transport.SenderContext<Message>
com.rabbitmq.client.amqp.observation.micrometer.PublishContext
All Implemented Interfaces:
io.micrometer.observation.Observation.ContextView
public class PublishContext extends io.micrometer.observation.transport.SenderContext<Message>
Publish context.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    correlationId()
     
    String
    exchange()
     
    String
    messageId()
     
    int
    payloadSizeBytes()
     
    String
    peerAddress()
     
    int
    peerPort()
     
    String
    routingKey()
     

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

    getCarrier, getKind, getRemoteServiceAddress, getRemoteServiceName, getSetter, 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

    Methods inherited from interface io.micrometer.observation.Observation.ContextView

    getOrDefault

  • Method Details

    • exchange

      public String exchange()

    • routingKey

      public String routingKey()

    • payloadSizeBytes

      public int payloadSizeBytes()

    • messageId

      public String messageId()

    • correlationId

      public String correlationId()

    • peerAddress

      public String peerAddress()

    • peerPort

      public int peerPort()