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

pack-priv final Class HAProxyMessageReader

extends ChannelInboundHandlerAdapter
Class Inheritance
Imports
java.net.InetSocketAddress, .SocketAddress, io.netty.channel.Channel, .ChannelHandlerContext, .ChannelInboundHandlerAdapter, io.netty.handler.codec.haproxy.HAProxyMessage, io.netty.util.AttributeKey, reactor.netty.transport.AddressUtils, reactor.util.annotation.Nullable
Consumes io.netty.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 io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline.
pack-priv static boolean
isProxyProtocolAvailable()

pack-priv static SocketAddress
resolveRemoteAddressFromProxyProtocol(Channel channel)

Inherited from io.netty.channel.ChannelInboundHandlerAdapter:
channelActivechannelInactivechannelReadCompletechannelRegisteredchannelUnregisteredchannelWritabilityChangedexceptionCaughtuserEventTriggered

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 io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Implements io.netty.channel.ChannelInboundHandler.channelRead.

Doc from io.netty.channel.ChannelInboundHandlerAdapter.channelRead.

Calls ChannelHandlerContext#fireChannelRead(Object) to forward to the next ChannelInboundHandler in the ChannelPipeline. Sub-classes may override this method to change behavior.

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