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 io.netty.channel.ChannelInboundHandler	decoder
protected final io.netty.channel.ChannelOutboundHandler	encoder
protected final ProtocolServer<A>	server
protected final NettyTransport	transport

Constructor Summary

Constructors

Constructor	Description
NettyChannelInitializer(ProtocolServer<A> server, NettyTransport transport, io.netty.channel.ChannelOutboundHandler encoder, io.netty.channel.ChannelInboundHandler decoder)

Method Summary

Modifier and Type	Method	Description
protected io.netty.handler.ssl.ApplicationProtocolConfig	getAlpnConfiguration()
void	initializeChannel(io.netty.channel.Channel ch)	Initialize netty channel

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

decoder

protected final io.netty.channel.ChannelInboundHandler decoder

Constructor Details

NettyChannelInitializer

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

Method Details

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

getAlpnConfiguration

protected io.netty.handler.ssl.ApplicationProtocolConfig getAlpnConfiguration()