org.waarp.ftp.core.data.handler

Class FtpDataInitializer

java.lang.Object

io.netty.channel.ChannelHandlerAdapter

io.netty.channel.ChannelInboundHandlerAdapter

io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

org.waarp.ftp.core.data.handler.FtpDataInitializer

All Implemented Interfaces:

io.netty.channel.ChannelHandler, io.netty.channel.ChannelInboundHandler

Direct Known Subclasses:

FtpsDataInitializer

public class FtpDataInitializer
extends io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

Pipeline Factory for Data Network.

Author:

Frederic Bregier

Nested Class Summary

Nested classes/interfaces inherited from interface io.netty.channel.ChannelHandler

io.netty.channel.ChannelHandler.Sharable

Field Summary

Fields

Modifier and Type	Field and Description
static String	CODEC_LIMIT Limit Codec
static String	CODEC_MODE Mode Codec
static String	CODEC_STRUCTURE Structure Codec
static String	CODEC_TYPE Type Codec
protected FtpConfiguration	configuration Configuration
protected Class<? extends DataBusinessHandler>	dataBusinessHandler Business Handler Class
protected static org.waarp.ftp.core.data.handler.FtpDataStructureCodec	ftpDataStructureCodec
protected static org.waarp.ftp.core.data.handler.FtpDataTypeCodec	ftpDataTypeCodec
static String	HANDLER Handler Codec
protected boolean	isActive Is this factory for Active mode
static String	PIPELINE_EXECUTOR Pipeline Executor Codec

Constructor Summary

Constructors

Constructor and Description
FtpDataInitializer(Class<? extends DataBusinessHandler> dataBusinessHandler, FtpConfiguration configuration, boolean active) Constructor which Initializes some data

Method Summary

Methods

Modifier and Type	Method and Description
void	initChannel(io.netty.channel.socket.SocketChannel ch) Create the pipeline with Handler, ObjectDecoder, ObjectEncoder.

Methods inherited from class io.netty.channel.ChannelInitializer

channelRegistered, exceptionCaught, handlerAdded, handlerRemoved

Methods inherited from class io.netty.channel.ChannelInboundHandlerAdapter

channelActive, channelInactive, channelRead, channelReadComplete, channelUnregistered, channelWritabilityChanged, userEventTriggered

Methods inherited from class io.netty.channel.ChannelHandlerAdapter

ensureNotSharable, isSharable

Methods inherited from class java.lang.Object

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

Field Detail

CODEC_MODE

public static final String CODEC_MODE

Mode Codec

See Also:

Constant Field Values

CODEC_LIMIT

public static final String CODEC_LIMIT

Limit Codec

See Also:

Constant Field Values

CODEC_TYPE

public static final String CODEC_TYPE

Type Codec

See Also:

Constant Field Values

CODEC_STRUCTURE

public static final String CODEC_STRUCTURE

Structure Codec

See Also:

Constant Field Values

PIPELINE_EXECUTOR

public static final String PIPELINE_EXECUTOR

Pipeline Executor Codec

See Also:

Constant Field Values

HANDLER

public static final String HANDLER

Handler Codec

See Also:

Constant Field Values

ftpDataTypeCodec

protected static final org.waarp.ftp.core.data.handler.FtpDataTypeCodec ftpDataTypeCodec

ftpDataStructureCodec

protected static final org.waarp.ftp.core.data.handler.FtpDataStructureCodec ftpDataStructureCodec

dataBusinessHandler

protected final Class<? extends DataBusinessHandler> dataBusinessHandler

Business Handler Class

configuration

protected final FtpConfiguration configuration

Configuration

isActive

protected final boolean isActive

Is this factory for Active mode

Constructor Detail

FtpDataInitializer

public FtpDataInitializer(Class<? extends DataBusinessHandler> dataBusinessHandler,
                  FtpConfiguration configuration,
                  boolean active)

Constructor which Initializes some data

Parameters:

dataBusinessHandler -

configuration -

active -

Method Detail

initChannel

public void initChannel(io.netty.channel.socket.SocketChannel ch)
                 throws Exception

Create the pipeline with Handler, ObjectDecoder, ObjectEncoder.

Specified by:

initChannel in class io.netty.channel.ChannelInitializer<io.netty.channel.socket.SocketChannel>

Throws:

Exception