Top Description Fields Constructors Methods
reactor.netty5.http.server

pack-priv final Class HAProxyMessageReader

extends ChannelHandlerAdapter
Class Inheritance
Imports
java.net.InetSocketAddress, .SocketAddress, io.netty5.channel.Channel, .ChannelHandlerAdapter, .ChannelHandlerContext, io.netty.contrib.handler.codec.haproxy.HAProxyMessage, io.netty5.util.AttributeKey, reactor.netty5.transport.AddressUtils, reactor.util.annotation.Nullable
Consumes io.netty.contrib.handler.codec.haproxy.HAProxyMessage and set it into channel attribute for later use.
Author
aftersss

Field Summary

Modifier and TypeField and Description
private static final boolean
isProxyProtocolAvailable

private static final AttributeKey<InetSocketAddress>
REMOTE_ADDRESS_FROM_PROXY_PROTOCOL

Constructor Summary

AccessConstructor and Description
pack-priv
HAProxyMessageReader()

Method Summary

Modifier and TypeMethod and Description
public void
channelRead(ChannelHandlerContext ctx, Object msg)

Overrides default io.netty5.channel.ChannelHandler.channelRead.

Invoked when the current Channel has read a message from the peer.
pack-priv static boolean
isProxyProtocolAvailable()

pack-priv static SocketAddress
resolveRemoteAddressFromProxyProtocol(Channel channel)

Field Detail

isProxyProtocolAvailableback to summary
private static final boolean isProxyProtocolAvailable
REMOTE_ADDRESS_FROM_PROXY_PROTOCOLback to summary
private static final AttributeKey<InetSocketAddress> REMOTE_ADDRESS_FROM_PROXY_PROTOCOL

Constructor Detail

HAProxyMessageReaderback to summary
pack-priv HAProxyMessageReader()

Method Detail

channelReadback to summary
public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception

Overrides default io.netty5.channel.ChannelHandler.channelRead.

Doc from io.netty5.channel.ChannelHandler.channelRead.

Invoked when the current Channel has read a message from the peer.

Annotations
@Override
isProxyProtocolAvailableback to summary
pack-priv static boolean isProxyProtocolAvailable()
resolveRemoteAddressFromProxyProtocolback to summary
pack-priv static SocketAddress resolveRemoteAddressFromProxyProtocol(Channel channel)
Annotations
@Nullable