Package org.infinispan.server.core.transport

Class NettyChannelInitializer<A extends ProtocolServerConfiguration>

java.lang.Object

org.infinispan.server.core.transport.NettyChannelInitializer<A>

All Implemented Interfaces:

NettyInitializer

Direct Known Subclasses:

RestChannelInitializer

public class NettyChannelInitializer<A extends ProtocolServerConfiguration>
extends Object
implements NettyInitializer

Pipeline factory for Netty-based channels. For each pipeline created, a new decoder is created which means that each incoming connection deals with a unique decoder instance. Since the encoder does not maintain any state, a single encoder instance is shared by all incoming connections, if and only if, the protocol mandates an encoder.

Since:

4.1

Author:

Galder Zamarreño, Sebastian Łaskawiec

Field Summary

Fields

Modifier and Type	Field	Description
protected final Supplier<io.netty.channel.ChannelInboundHandler>	decoderSupplier
protected final io.netty.channel.ChannelOutboundHandler	encoder
protected final io.netty.util.Mapping<? super String,? extends io.netty.handler.ssl.SslContext>	mapping
protected final ProtocolServer<A>	server
protected final NettyTransport	transport

Constructor Summary

Constructors

Modifier	Constructor	Description
	NettyChannelInitializer(ProtocolServer<A> server, NettyTransport transport, io.netty.channel.ChannelOutboundHandler encoder, Supplier<io.netty.channel.ChannelInboundHandler> decoderSupplier)
protected	NettyChannelInitializer(ProtocolServer<A> server, NettyTransport transport, io.netty.channel.ChannelOutboundHandler encoder, Supplier<io.netty.channel.ChannelInboundHandler> decoderSupplier, io.netty.handler.ssl.ApplicationProtocolConfig alpnConfiguration)

Method Summary

Modifier and Type	Method	Description
void	initializeChannel(io.netty.channel.Channel ch)	Initialize netty channel
protected io.netty.util.Mapping<? super String,? extends io.netty.handler.ssl.SslContext>	initMapping(io.netty.handler.ssl.ApplicationProtocolConfig alpnConfiguration)

Methods inherited from class java.lang.Object

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

Field Details

server

protected final ProtocolServer<A extends ProtocolServerConfiguration> server

transport

protected final NettyTransport transport

encoder

protected final io.netty.channel.ChannelOutboundHandler encoder

decoderSupplier

protected final Supplier<io.netty.channel.ChannelInboundHandler> decoderSupplier

mapping

protected final io.netty.util.Mapping<? super String,? extends io.netty.handler.ssl.SslContext> mapping

Constructor Details

NettyChannelInitializer

public NettyChannelInitializer(ProtocolServer<A> server,
 NettyTransport transport,
 io.netty.channel.ChannelOutboundHandler encoder,
 Supplier<io.netty.channel.ChannelInboundHandler> decoderSupplier)

NettyChannelInitializer

protected NettyChannelInitializer(ProtocolServer<A> server,
 NettyTransport transport,
 io.netty.channel.ChannelOutboundHandler encoder,
 Supplier<io.netty.channel.ChannelInboundHandler> decoderSupplier,
 io.netty.handler.ssl.ApplicationProtocolConfig alpnConfiguration)

Method Details

initMapping

protected io.netty.util.Mapping<? super String,? extends io.netty.handler.ssl.SslContext> initMapping(io.netty.handler.ssl.ApplicationProtocolConfig alpnConfiguration)

initializeChannel

public void initializeChannel(io.netty.channel.Channel ch)
                       throws Exception

Description copied from interface: NettyInitializer

Initialize netty channel

Specified by:

initializeChannel in interface NettyInitializer

Parameters:

ch -

Throws:

Exception