reactor.netty.contextpropagation

Class ChannelContextAccessor

java.lang.Object

reactor.netty.contextpropagation.ChannelContextAccessor

public final class ChannelContextAccessor
extends Object

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 io.netty.channel.Channel>	readableType()
<T> T	readValue(io.netty.channel.Channel sourceContext, Object key)
void	readValues(io.netty.channel.Channel sourceContext, Predicate<Object> keyPredicate, Map<Object,Object> readValues)
Class<? extends io.netty.channel.Channel>	writeableType()
io.netty.channel.Channel	writeValues(Map<Object,Object> valuesToWrite, io.netty.channel.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 io.netty.channel.Channel> readableType()

readValues

public void readValues(io.netty.channel.Channel sourceContext,
                       Predicate<Object> keyPredicate,
                       Map<Object,Object> readValues)

readValue

@Nullable
public <T> T readValue(io.netty.channel.Channel sourceContext,
                                 Object key)

writeableType

public Class<? extends io.netty.channel.Channel> writeableType()

writeValues

public io.netty.channel.Channel writeValues(Map<Object,Object> valuesToWrite,
                                            io.netty.channel.Channel targetContext)