org.apache.james.smtpserver.netty

Class SMTPServer

java.lang.Object

org.apache.james.protocols.netty.AbstractAsyncServer

org.apache.james.protocols.lib.netty.AbstractConfigurableAsyncServer

org.apache.james.protocols.lib.netty.AbstractProtocolAsyncServer

org.apache.james.smtpserver.netty.SMTPServer

All Implemented Interfaces:

Configurable, LogEnabled, org.apache.james.protocols.api.ProtocolServer, ServerMBean, org.apache.james.protocols.smtp.SMTPServerMBean

Direct Known Subclasses:

OioSMTPServer

public class SMTPServer
extends AbstractProtocolAsyncServer
implements SMTPServerMBean

NIO SMTPServer which use Netty

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	SMTPServer.SMTPHandlerConfigurationDataImpl A class to provide SMTP handler configuration to the handlers

Field Summary

Fields inherited from class org.apache.james.protocols.lib.netty.AbstractConfigurableAsyncServer

connectionLimit, connPerIP, DEFAULT_BACKLOG, DEFAULT_MAX_EXECUTOR_COUNT, DEFAULT_TIMEOUT, HELLO_NAME, jmxName

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

DEFAULT_IO_WORKER_COUNT

Constructor Summary

Constructors

Constructor and Description
SMTPServer()

Method Summary

Methods

Modifier and Type	Method and Description
protected org.jboss.netty.channel.ChannelUpstreamHandler	createCoreHandler()
void	doConfigure(org.apache.commons.configuration.HierarchicalConfiguration configuration)
boolean	getAddressBracketsEnforcement() Return true if brackets around addresses in the MAIL and RCPT are required
protected Class<? extends HandlersPackage>	getCoreHandlersPackage() Return the HandlersPackage which is responsible to load the core ProtocolHandler
protected String	getDefaultJMXName() Return the default name of the the server in JMX if none is configured via "jmxname" in the configuration
protected int	getDefaultPort() Return the default port which will get used for this server if non is specify in the configuration
boolean	getHeloEhloEnforcement() Return true if a HELO/EHLO is required when connecting to this server
String	getHeloName() Return the hello name
protected Class<? extends HandlersPackage>	getJMXHandlersPackage() Return the HandlersPackage which is responsible to load the jmx ProtocolHandler
long	getMaximalMessageSize() Return the maximum allowed size of the message
String	getServiceType() Return the service type of the server
protected void	preInit() This method is called on init of the Server.
void	setAddressBracketsEnforcement(boolean enforceAddressBrackets) Enable or disable brackets enforcement around addressed in the MAIL and RCPT command
void	setDNSService(DNSService dns)
void	setHeloEhloEnforcement(boolean enforceHeloEHlo) Enable or disable the need of the HELO/EHLO
void	setMaximalMessageSize(long maxSize) Set the maximum allowed size of messages.

Methods inherited from class org.apache.james.protocols.lib.netty.AbstractProtocolAsyncServer

getProtocolHandlerChain, postDestroy, setProtocolHandlerLoader

Methods inherited from class org.apache.james.protocols.lib.netty.AbstractConfigurableAsyncServer

configure, configureBootstrap, configureHelloName, createBossExecutor, createExecutionHander, createPipelineFactory, createWorkerExecutor, destroy, getBoundAddresses, getConnectionCountHandler, getCurrentConnections, getEnabledCipherSuites, getEncryption, getExecutionHandler, getFileSystem, getHandledConnections, getHelloName, getLogger, getMaximumConcurrentConnections, getSocketType, getStartTLSSupported, getThreadPoolJMXPath, init, isEnabled, isStarted, registerMBean, setFileSystem, setLog, start, stop, unregisterMBean

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

bind, createSocketChannelFactory, 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

Methods inherited from interface org.apache.james.protocols.smtp.SMTPServerMBean

getSocketType, isEnabled

Methods inherited from interface org.apache.james.protocols.lib.jmx.ServerMBean

getBoundAddresses, getCurrentConnections, getHandledConnections, getMaximumConcurrentConnections, getSocketType, getStartTLSSupported, getTimeout, isEnabled, isStarted, start, stop

Constructor Detail

SMTPServer

public SMTPServer()

Method Detail

setDNSService

public void setDNSService(DNSService dns)

preInit

protected void preInit()
                throws Exception

Description copied from class: AbstractConfigurableAsyncServer

This method is called on init of the Server. Subclasses should override this method to init stuff

Overrides:

preInit in class AbstractProtocolAsyncServer

Throws:

Exception

doConfigure

public void doConfigure(org.apache.commons.configuration.HierarchicalConfiguration configuration)
                 throws org.apache.commons.configuration.ConfigurationException

Overrides:

doConfigure in class AbstractProtocolAsyncServer

Throws:

org.apache.commons.configuration.ConfigurationException

getDefaultPort

protected int getDefaultPort()

Return the default port which will get used for this server if non is specify in the configuration

Specified by:

getDefaultPort in class AbstractConfigurableAsyncServer

Returns:

port

getServiceType

public String getServiceType()

Description copied from interface: ServerMBean

Return the service type of the server

Specified by:

getServiceType in interface ServerMBean

See Also:

ServerMBean.getServiceType()

getMaximalMessageSize

public long getMaximalMessageSize()

Description copied from interface: SMTPServerMBean

Return the maximum allowed size of the message

Returns:

maxMessageSize

See Also:

SMTPServerMBean.getMaximalMessageSize()

getAddressBracketsEnforcement

public boolean getAddressBracketsEnforcement()

Description copied from interface: SMTPServerMBean

Return true if brackets around addresses in the MAIL and RCPT are required

Returns:

bracketsEnforcement

See Also:

SMTPServerMBean.getAddressBracketsEnforcement()

getHeloEhloEnforcement

public boolean getHeloEhloEnforcement()

Description copied from interface: SMTPServerMBean

Return true if a HELO/EHLO is required when connecting to this server

Returns:

heloEhloEnforcement

See Also:

SMTPServerMBean.getHeloEhloEnforcement()

getDefaultJMXName

protected String getDefaultJMXName()

Description copied from class: AbstractConfigurableAsyncServer

Return the default name of the the server in JMX if none is configured via "jmxname" in the configuration

Specified by:

getDefaultJMXName in class AbstractConfigurableAsyncServer

Returns:

defaultJmxName

See Also:

AbstractConfigurableAsyncServer.getDefaultJMXName()

setMaximalMessageSize

public void setMaximalMessageSize(long maxSize)

Description copied from interface: SMTPServerMBean

Set the maximum allowed size of messages. Set this to 0 to accept every message

See Also:

SMTPServerMBean.setMaximalMessageSize(long)

setAddressBracketsEnforcement

public void setAddressBracketsEnforcement(boolean enforceAddressBrackets)

Description copied from interface: SMTPServerMBean

Enable or disable brackets enforcement around addressed in the MAIL and RCPT command

See Also:

SMTPServerMBean.setAddressBracketsEnforcement(boolean)

setHeloEhloEnforcement

public void setHeloEhloEnforcement(boolean enforceHeloEHlo)

Description copied from interface: SMTPServerMBean

Enable or disable the need of the HELO/EHLO

See Also:

SMTPServerMBean.setHeloEhloEnforcement(boolean)

getHeloName

public String getHeloName()

Description copied from interface: SMTPServerMBean

Return the hello name

Returns:

helo

See Also:

SMTPServerMBean.getHeloName()

createCoreHandler

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

Specified by:

createCoreHandler in class AbstractConfigurableAsyncServer

getCoreHandlersPackage

protected Class<? extends HandlersPackage> getCoreHandlersPackage()

Description copied from class: AbstractProtocolAsyncServer

Return the HandlersPackage which is responsible to load the core ProtocolHandler

Specified by:

getCoreHandlersPackage in class AbstractProtocolAsyncServer

Returns:

core

getJMXHandlersPackage

protected Class<? extends HandlersPackage> getJMXHandlersPackage()

Description copied from class: AbstractProtocolAsyncServer

Return the HandlersPackage which is responsible to load the jmx ProtocolHandler

Specified by:

getJMXHandlersPackage in class AbstractProtocolAsyncServer

Returns:

jmx