Package org.apache.mina.transport.socket.nio

Class SocketAcceptor

java.lang.Object

org.apache.mina.common.support.BaseIoService

org.apache.mina.common.support.BaseIoAcceptor

org.apache.mina.transport.socket.nio.SocketAcceptor

All Implemented Interfaces:

IoAcceptor, IoService

public class SocketAcceptor
extends BaseIoAcceptor

IoAcceptor for socket transport (TCP/IP).

Constructor Summary

Constructors

Constructor	Description
SocketAcceptor()	Create an acceptor with a single processing thread using a NewThreadExecutor
SocketAcceptor(int processorCount, java.util.concurrent.Executor executor)	Create an acceptor with the desired number of processing threads

Method Summary

Modifier and Type	Method	Description
void	bind(java.net.SocketAddress address, IoHandler handler, IoServiceConfig config)	Binds to the specified address and handles incoming connections with the specified handler.
SocketAcceptorConfig	getDefaultConfig()	Returns the default configuration which is used when you didn't specify any configuration.
void	setDefaultConfig(SocketAcceptorConfig defaultConfig)	Sets the config this acceptor will use by default.
void	unbind(java.net.SocketAddress address)	Unbinds from the specified address and disconnects all clients connected there.
void	unbindAll()	Unbinds all addresses which were bound by this acceptor.

Methods inherited from class org.apache.mina.common.support.BaseIoAcceptor

bind, newSession

Methods inherited from class org.apache.mina.common.support.BaseIoService

addListener, getFilterChain, getFilterChainBuilder, getListeners, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.mina.common.IoService

addListener, getFilterChain, getFilterChainBuilder, getManagedServiceAddresses, getManagedSessions, isManaged, removeListener, setFilterChainBuilder

Constructor Detail

SocketAcceptor

public SocketAcceptor()

Create an acceptor with a single processing thread using a NewThreadExecutor

SocketAcceptor

public SocketAcceptor(int processorCount,
                      java.util.concurrent.Executor executor)

Create an acceptor with the desired number of processing threads

Parameters:

processorCount - Number of processing threads

executor - Executor to use for launching threads

Method Detail

bind

public void bind(java.net.SocketAddress address,
                 IoHandler handler,
                 IoServiceConfig config)
          throws java.io.IOException

Binds to the specified address and handles incoming connections with the specified handler. Backlog value is configured to the value of backlog property.

config - the configuration

Throws:

java.io.IOException - if failed to bind

unbind

public void unbind(java.net.SocketAddress address)

Description copied from interface: IoAcceptor

Unbinds from the specified address and disconnects all clients connected there.

unbindAll

public void unbindAll()

Description copied from interface: IoAcceptor

Unbinds all addresses which were bound by this acceptor.

getDefaultConfig

public SocketAcceptorConfig getDefaultConfig()

Description copied from interface: IoService

Returns the default configuration which is used when you didn't specify any configuration.

setDefaultConfig

public void setDefaultConfig(SocketAcceptorConfig defaultConfig)

Sets the config this acceptor will use by default.

Parameters:

defaultConfig - the default config.

Throws:

java.lang.NullPointerException - if the specified value is null.