com.epam.common.transport.server.tcp

Class NIOTCPServer

java.lang.Object

com.epam.common.transport.server.AbstractServer

com.epam.common.transport.server.tcp.TCPServer

com.epam.common.transport.server.tcp.NIOTCPServer

All Implemented Interfaces:

Server

public class NIOTCPServer
extends TCPServer

TCP server implementation.

Field Summary

Fields inherited from class com.epam.common.transport.server.tcp.TCPServer

DEFAULT_BACKLOG

Fields inherited from class com.epam.common.transport.server.AbstractServer

autoClose, DEFAULT_PORT, port, sessionRefCounter, started

Constructor Summary

Constructors

Constructor and Description
NIOTCPServer() Creates server with default port.
NIOTCPServer(int port) Creates server.
NIOTCPServer(int port, boolean enableNagle) Creates server.
NIOTCPServer(int port, boolean enableNagle, String nic) Creates server.
NIOTCPServer(int port, boolean enableNagle, String nic, int sendBufferSize, int receiveBufferSize, Map<String,Object> connectivityParams) Creates server.

Method Summary

Modifier and Type	Method and Description
void	setConnectivityParams(Map<String,Object> connectivityParams)
void	setIncomingConnectionListener(ConnectionListener listener) Sets the connection listener.
void	start() Start the server.
void	stop() Stop server.

Methods inherited from class com.epam.common.transport.server.tcp.TCPServer

createServerSocket, createServerSocket, setIncomingConnectionExecutor, setServerSocketFactory, toString

Methods inherited from class com.epam.common.transport.server.AbstractServer

decrementRefCounter, getPort, incrementRefCounter, isAutoClose, isStarted, setAutoClose, setPort, setStarted

Methods inherited from class java.lang.Object

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

Methods inherited from interface com.epam.common.transport.server.Server

asAbstract, isAbstract

Constructor Detail

NIOTCPServer

public NIOTCPServer()

Creates server with default port. The default value for port is 3001

NIOTCPServer

public NIOTCPServer(int port)

Creates server.

Parameters:

port - - server port

NIOTCPServer

public NIOTCPServer(int port,
                    boolean enableNagle)

Creates server.

Parameters:

port - - server port

enableNagle - - enable/disable nagle algorithm

NIOTCPServer

public NIOTCPServer(int port,
                    boolean enableNagle,
                    String nic,
                    int sendBufferSize,
                    int receiveBufferSize,
                    Map<String,Object> connectivityParams)

Creates server.

Parameters:

port - server port

enableNagle - enable/disable nagle algorithm

sendBufferSize - send buffer size

receiveBufferSize - receive buffer size

connectivityParams - connectivity params for transport

NIOTCPServer

public NIOTCPServer(int port,
                    boolean enableNagle,
                    String nic)

Creates server.

Parameters:

port - - server port

enableNagle - - enable/disable nagle algorithm

nic - - specific connection address

Method Detail

setConnectivityParams

public void setConnectivityParams(Map<String,Object> connectivityParams)

setIncomingConnectionListener

public void setIncomingConnectionListener(ConnectionListener listener)

Description copied from interface: Server

Sets the connection listener.

Specified by:

setIncomingConnectionListener in interface Server

Overrides:

setIncomingConnectionListener in class TCPServer

Parameters:

listener - the connection listener

See Also:

Server.setIncomingConnectionListener(com.epam.common.transport.server.ConnectionListener)

start

public void start()
           throws IOException

Description copied from interface: Server

Start the server.

Specified by:

start in interface Server

Overrides:

start in class TCPServer

Throws:

IOException - - if error occurred

See Also:

Server.start()

stop

public void stop()
          throws IOException

Description copied from interface: Server

Stop server.

Specified by:

stop in interface Server

Overrides:

stop in class TCPServer

Throws:

IOException - - if error occurred

See Also:

Server.stop()