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 Summary

Constructors

Constructor and Description
ChannelContextAccessor()

Method Summary

Modifier and Type	Method and Description
Class<? extends Channel>	readableType()
<T> T	readValue(Channel sourceContext, Object key)
void	readValues(Channel sourceContext, Predicate<Object> keyPredicate, Map<Object,Object> readValues)
Class<? extends Channel>	writeableType()
Channel	writeValues(Map<Object,Object> valuesToWrite, Channel targetContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

ChannelContextAccessor

public ChannelContextAccessor()

Method Detail

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

@Nullable
public <T> 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>