Package reactor.netty.contextpropagation

Class ChannelContextAccessor

java.lang.Object
reactor.netty.contextpropagation.ChannelContextAccessor
All Implemented Interfaces:
io.micrometer.context.ContextAccessor<Channel,Channel>
public final class ChannelContextAccessor extends Object implements io.micrometer.context.ContextAccessor<Channel,Channel>
A ContextAccessor to enable reading values from a Netty Channel and writing values to a Netty Channel.

Note: This public class implements the io.micrometer:context-propagation SPI library, which is an optional dependency.

Since:
1.0.26
Author:
Violeta Georgieva

  • Constructor Details

    • ChannelContextAccessor

      public ChannelContextAccessor()

  • Method Details

    • readableType

      public Class<? extends Channel> readableType()
      Specified by:
      readableType in interface io.micrometer.context.ContextAccessor<Channel,Channel>

    • readValues

      public void readValues(Channel sourceContext, Predicate<Object> keyPredicate, Map<Object,Object> readValues)
      Specified by:
      readValues in interface io.micrometer.context.ContextAccessor<Channel,Channel>

    • readValue

      public <T> @Nullable T readValue(Channel sourceContext, Object key)
      Specified by:
      readValue in interface io.micrometer.context.ContextAccessor<Channel,Channel>

    • writeableType

      public Class<? extends Channel> writeableType()
      Specified by:
      writeableType in interface io.micrometer.context.ContextAccessor<Channel,Channel>

    • writeValues

      public Channel writeValues(Map<Object,Object> valuesToWrite, Channel targetContext)
      Specified by:
      writeValues in interface io.micrometer.context.ContextAccessor<Channel,Channel>