Class ProcessContext

java.lang.Object
io.micrometer.observation.Observation.Context
io.micrometer.observation.transport.ReceiverContext<Message>
com.rabbitmq.stream.observation.micrometer.ProcessContext
All Implemented Interfaces:
io.micrometer.observation.Observation.ContextView
public class ProcessContext extends io.micrometer.observation.transport.ReceiverContext<Message>
Observation.Context for RabbitMQ Stream consuming.
Since:
0.12.0

  • Method Summary

    Modifier and Type
    Method
    Description
    int
    getPayloadSizeBytes()
     
    String
    getStream()
     

    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 Object

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

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

    getOrDefault

  • Method Details

    • getStream

      public String getStream()

    • getPayloadSizeBytes

      public int getPayloadSizeBytes()