org.apache.james.protocols.netty

Class NettyServer

java.lang.Object

org.apache.james.protocols.netty.AbstractAsyncServer

org.apache.james.protocols.netty.NettyServer

All Implemented Interfaces:

ProtocolServer

public class NettyServer
extends AbstractAsyncServer

Generic NettyServer

Field Summary

Fields

Modifier and Type	Field and Description
protected Protocol	protocol
protected Encryption	secure

Fields inherited from class org.apache.james.protocols.netty.AbstractAsyncServer

DEFAULT_IO_WORKER_COUNT

Constructor Summary

Constructors

Constructor and Description
NettyServer(Protocol protocol)
NettyServer(Protocol protocol, Encryption secure)

Method Summary

Methods

Modifier and Type	Method and Description
void	bind() Start the server
protected org.jboss.netty.channel.ChannelUpstreamHandler	createCoreHandler()
protected org.jboss.netty.handler.execution.ExecutionHandler	createExecutionHandler(int size)
protected org.jboss.netty.channel.ChannelPipelineFactory	createPipelineFactory(org.jboss.netty.channel.group.ChannelGroup group) Create ChannelPipelineFactory to use by this Server implementation
void	setMaxConcurrentConnections(int maxCurConnections)
void	setMaxConcurrentConnectionsPerIP(int maxCurConnectionsPerIP)
void	setUseExecutionHandler(boolean useHandler, int size) Set true if an ExecutionHandler should be used to hand over the tasks.

Methods inherited from class org.apache.james.protocols.netty.AbstractAsyncServer

configureBootstrap, createBossExecutor, createSocketChannelFactory, createWorkerExecutor, getBacklog, getIoWorkerCount, getListenAddresses, getTimeout, isBound, setBacklog, setIoWorkerCount, setListenAddresses, setTimeout, unbind

Methods inherited from class java.lang.Object

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

Field Detail

protocol

protected final Protocol protocol

secure

protected final Encryption secure

Constructor Detail

NettyServer

public NettyServer(Protocol protocol)

NettyServer

public NettyServer(Protocol protocol,
           Encryption secure)

Method Detail

createExecutionHandler

protected org.jboss.netty.handler.execution.ExecutionHandler createExecutionHandler(int size)

setUseExecutionHandler

public void setUseExecutionHandler(boolean useHandler,
                          int size)

Set true if an ExecutionHandler should be used to hand over the tasks. This should be done if you have some ProtocolHandler's which need to full fill some blocking operation.

Parameters:

useHandler - true if an ExecutionHandler should be used

size - the thread count to use

setMaxConcurrentConnections

public void setMaxConcurrentConnections(int maxCurConnections)

setMaxConcurrentConnectionsPerIP

public void setMaxConcurrentConnectionsPerIP(int maxCurConnectionsPerIP)

createCoreHandler

protected org.jboss.netty.channel.ChannelUpstreamHandler createCoreHandler()

bind

public void bind()
          throws Exception

Description copied from interface: ProtocolServer

Start the server

Specified by:

bind in interface ProtocolServer

Overrides:

bind in class AbstractAsyncServer

Throws:

Exception

createPipelineFactory

protected org.jboss.netty.channel.ChannelPipelineFactory createPipelineFactory(org.jboss.netty.channel.group.ChannelGroup group)

Description copied from class: AbstractAsyncServer

Create ChannelPipelineFactory to use by this Server implementation

Specified by:

createPipelineFactory in class AbstractAsyncServer

Returns:

factory