Package org.objectweb.joram.mom.proxies.tcp

Class TcpProxyService

java.lang.Object

org.objectweb.joram.mom.proxies.tcp.TcpProxyService

All Implemented Interfaces:

ConnectionManagerMBean, TcpProxyServiceMBean

Direct Known Subclasses:

SSLTcpProxyService

public class TcpProxyService
extends Object
implements TcpProxyServiceMBean

Starts a TCP entry point for MOM clients.

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	activated
private String	address
private int	backlog
static String	BACKLOG_PROP	Name the property that allow to fix the TCP BACKLOG property for the client's connections.
private static boolean	cnxWithNoAckedQueue
private TcpConnectionListener[]	connectionListeners	The thread listening to incoming TCP connections.
private Vector<TcpConnection>	connections	The list of opened connections
private static boolean	DEBUG
static int	DEFAULT_BACKLOG	Default value for the TCP BACKLOG property.
static String	DEFAULT_BINDADDRESS	Default IP address for binding the listen socket.
static int	DEFAULT_POOL_SIZE	Default value for the pool size.
static int	DEFAULT_PORT	Default value for the TCP port of the listen socket.
static int	DEFAULT_SO_TIMEOUT	Default value for the TCP SO_TIMEOUT property.
private static ExecutorService	executorService
private static Logger	logger	logger
private static String	MBEAN_NAME
static String	POOL_SIZE_PROP	Name the property that allow to fix the pool size for the connection's listener.
private int	port
private static TcpProxyService	proxyService	The proxy service reference (used to stop it).
private ServerSocket	serverSocket	The server socket listening to connections from the JMS clients.
static String	SO_TIMEOUT_PROP	Name the property that allow to fix the TCP SO_TIMEOUT property for the client's connections.

Constructor Summary

Constructors

Constructor	Description
TcpProxyService(int port, int backlog, String address)

Method Summary

Modifier and Type	Method	Description
void	activate()	Activates the TcpProxyService (TCP/JMS connector), creates the socket and starts listeners.
void	closeAllConnections()	Closes all active connections.
static void	createExecutors()
protected ServerSocket	createServerSocket(int port, int backlog, String address)	Initialize the listening socket.
void	deactivate()	Deactivates the TcpProxyService (TCP/JMS connector), stops all listeners.
static void	execute(Runnable command)
long	getAverageConnectionTime()	Gets the average time for incoming tcp connections.
(package private) TcpConnection	getConnection(AgentId proxyId, int key)
int	getFailedLoginCount()	Gets the number of failed login.
int	getInitiatedConnectionCount()	Gets the number of connections initiated since boot time.
int	getListenPort()	Gets the listen port of the server.
String	getMBeanName()	Gets the name of the MBean.
int	getProtocolErrorCount()	Gets the number of connections rejected due to a wrong protocol header.
int	getRunningConnectionsCount()	Gets the number of active connections.
String	getServerAddress()	Gets the socket address of the server.
(package private) ServerSocket	getServerSocket()	Gets the listening socket.
int	getTcpListenersPoolSize()	Gets the number of threads listening for incoming tcp connections.
String	getVersion()	Gets the name of the MBean.
static void	init(String args, boolean firstTime)	Initializes the TCP entry point by creating a server socket listening to the specified port.
boolean	isActivated()	Returns true if the TcpProxyService (TCP/JMS connector) is started.
static boolean	isExecutor()
(package private) void	registerConnection(TcpConnection tcpConnection)
static void	removeExecutors()
protected void	resetServerSocket()	Closes the listening socket and sets the variable to null.
protected void	start()
private void	stop()
static void	stopService()	Stops the service.
(package private) void	unregisterConnection(TcpConnection tcpConnection)

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

logger

DEBUG

private static final boolean DEBUG

SO_TIMEOUT_PROP

public static final String SO_TIMEOUT_PROP

Name the property that allow to fix the TCP SO_TIMEOUT property for the client's connections.

See Also:

Constant Field Values

DEFAULT_SO_TIMEOUT

public static final int DEFAULT_SO_TIMEOUT

Default value for the TCP SO_TIMEOUT property.

See Also:

Constant Field Values

POOL_SIZE_PROP

public static final String POOL_SIZE_PROP

Name the property that allow to fix the pool size for the connection's listener.

See Also:

Constant Field Values

DEFAULT_POOL_SIZE

public static final int DEFAULT_POOL_SIZE

Default value for the pool size.

See Also:

Constant Field Values

BACKLOG_PROP

public static final String BACKLOG_PROP

Name the property that allow to fix the TCP BACKLOG property for the client's connections.

See Also:

Constant Field Values

DEFAULT_BACKLOG

public static final int DEFAULT_BACKLOG

Default value for the TCP BACKLOG property.

See Also:

Constant Field Values

DEFAULT_PORT

public static final int DEFAULT_PORT

Default value for the TCP port of the listen socket.

See Also:

Constant Field Values

DEFAULT_BINDADDRESS

public static final String DEFAULT_BINDADDRESS

Default IP address for binding the listen socket.

See Also:

Constant Field Values

MBEAN_NAME

private static final String MBEAN_NAME

See Also:

Constant Field Values

proxyService

private static TcpProxyService proxyService

The proxy service reference (used to stop it).

executorService

private static ExecutorService executorService

cnxWithNoAckedQueue

private static boolean cnxWithNoAckedQueue

port

private int port

backlog

private int backlog

address

private String address

serverSocket

private ServerSocket serverSocket

The server socket listening to connections from the JMS clients.

connections

private Vector<TcpConnection> connections

The list of opened connections

connectionListeners

private TcpConnectionListener[] connectionListeners

The thread listening to incoming TCP connections.

activated

private boolean activated

Constructor Detail

TcpProxyService

public TcpProxyService(int port,
                       int backlog,
                       String address)
                throws Exception

Throws:

Exception

Method Detail

isExecutor

public static boolean isExecutor()

getServerSocket

ServerSocket getServerSocket()

Gets the listening socket.

Returns:

the listening socket.

resetServerSocket

protected void resetServerSocket()

Closes the listening socket and sets the variable to null.

createServerSocket

protected ServerSocket createServerSocket(int port,
                                          int backlog,
                                          String address)
                                   throws Exception

Initialize the listening socket.

Parameters:

port -

backlog -

address -

Returns:

The initialized socket.

Throws:

Exception

getVersion

public String getVersion()

Description copied from interface: ConnectionManagerMBean

Gets the name of the MBean.

Specified by:

getVersion in interface ConnectionManagerMBean

init

public static void init(String args,
                        boolean firstTime)
                 throws Exception

Initializes the TCP entry point by creating a server socket listening to the specified port.

Parameters:

args - stringified listening port

firstTime - true when the agent server starts.

Throws:

Exception

stopService

public static void stopService()

Stops the service.

start

protected void start()

getMBeanName

public String getMBeanName()

Description copied from interface: ConnectionManagerMBean

Gets the name of the MBean.

Specified by:

getMBeanName in interface ConnectionManagerMBean

registerConnection

void registerConnection(TcpConnection tcpConnection)

unregisterConnection

void unregisterConnection(TcpConnection tcpConnection)

getConnection

TcpConnection getConnection(AgentId proxyId,
                            int key)

stop

private void stop()

activate

public void activate()

Activates the TcpProxyService (TCP/JMS connector), creates the socket and starts listeners.

Specified by:

activate in interface ConnectionManagerMBean

Specified by:

activate in interface TcpProxyServiceMBean

createExecutors

public static void createExecutors()

removeExecutors

public static void removeExecutors()

execute

public static void execute(Runnable command)

closeAllConnections

public void closeAllConnections()

Closes all active connections.

Specified by:

closeAllConnections in interface ConnectionManagerMBean

Specified by:

closeAllConnections in interface TcpProxyServiceMBean

deactivate

public void deactivate()

Deactivates the TcpProxyService (TCP/JMS connector), stops all listeners.

Specified by:

deactivate in interface ConnectionManagerMBean

Specified by:

deactivate in interface TcpProxyServiceMBean

isActivated

public boolean isActivated()

Returns true if the TcpProxyService (TCP/JMS connector) is started.

Specified by:

isActivated in interface ConnectionManagerMBean

Specified by:

isActivated in interface TcpProxyServiceMBean

Returns:

true if the TcpProxyService is started.

getRunningConnectionsCount

public int getRunningConnectionsCount()

Gets the number of active connections.

Specified by:

getRunningConnectionsCount in interface ConnectionManagerMBean

Specified by:

getRunningConnectionsCount in interface TcpProxyServiceMBean

Returns:

the number of active connections.

getTcpListenersPoolSize

public int getTcpListenersPoolSize()

Gets the number of threads listening for incoming tcp connections.

Specified by:

getTcpListenersPoolSize in interface TcpProxyServiceMBean

Returns:

the tcp listeners pool size.

getAverageConnectionTime

public long getAverageConnectionTime()

Gets the average time for incoming tcp connections.

Specified by:

getAverageConnectionTime in interface TcpProxyServiceMBean

Returns:

the average time for incoming tcp connections.

getListenPort

public int getListenPort()

Gets the listen port of the server.

Specified by:

getListenPort in interface TcpProxyServiceMBean

Returns:

the listen port of the server.

getServerAddress

public String getServerAddress()

Gets the socket address of the server.

Specified by:

getServerAddress in interface TcpProxyServiceMBean

Returns:

the server socket address.

getFailedLoginCount

public int getFailedLoginCount()

Gets the number of failed login.

Specified by:

getFailedLoginCount in interface ConnectionManagerMBean

Specified by:

getFailedLoginCount in interface TcpProxyServiceMBean

Returns:

the number of failed login.

getInitiatedConnectionCount

public int getInitiatedConnectionCount()

Gets the number of connections initiated since boot time.

Specified by:

getInitiatedConnectionCount in interface ConnectionManagerMBean

Specified by:

getInitiatedConnectionCount in interface TcpProxyServiceMBean

Returns:

the number of connections initiated since boot time.

getProtocolErrorCount

public int getProtocolErrorCount()

Gets the number of connections rejected due to a wrong protocol header.

Specified by:

getProtocolErrorCount in interface TcpProxyServiceMBean

Returns:

the number of connections rejected due to a wrong protocol header.