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

Class TcpConnection

java.lang.Object

org.objectweb.joram.mom.proxies.tcp.TcpConnection

All Implemented Interfaces:

ProxyMessageSender, TcpConnectionMBean

public class TcpConnection
extends Object
implements TcpConnectionMBean, ProxyMessageSender

Handles the TCP connection. Starts the reader and writer threads responsible for reading the requests and writing the replies. Calls the UserConnection in order to invoke the user's proxy and get its replies.

See Also:

TcpProxyService, TcpConnectionListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closeConnection
private Date	creationDate
private ReliableConnectionContext	ctx
private static boolean	DEBUG
private Identity	identity
private IOControl	ioctrl
private static Logger	logger	logger
private AgentId	proxyId
private TcpProxyService	proxyService	The TCP proxy service used to register and unregister this connection.
private TcpReader	tcpReader	The reader thread responsible for reading the requests (input).
private TcpWriter	tcpWriter	The writer thread responsible for writing the replies (output).

Constructor Summary

Constructors

Constructor	Description
TcpConnection(IOControl ioctrl, ReliableConnectionContext ctx, AgentId proxyId, TcpProxyService proxyService, Identity identity)	Creates a new TCP connection.

Method Summary

Modifier and Type	Method	Description
void	close()	Stops the connection reader and writer threads.
void	execute(Runnable runnable)	Executes a task.
int	getAckedQueueSize()	Gets the AckedQueue size.
String	getAddress()	Gets the socket address used by the connection.
Date	getCreationDate()	Gets connection creation date.
int	getKey()
private String	getMBeanName()
AgentId	getProxyId()
int	getQueueWorkerSize()	Gets the QueueWorker size.
int	getReaderQueueSize()	Gets the ReaderQueue size.
long	getReceivedCount()	Gets the number of replies received on the connection.
long	getSentCount()	Gets the number of requests sent on the connection.
String	getUserName()	Gets connected user's name.
boolean	isExecutor()	States whether executing a task is allowed.
void	send(ProxyMessage msg)	Sends a message to the client.
(package private) void	start()	Starts the connection reader and writer threads.

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

ioctrl

private IOControl ioctrl

proxyId

private AgentId proxyId

ctx

private ReliableConnectionContext ctx

tcpReader

private TcpReader tcpReader

The reader thread responsible for reading the requests (input).

tcpWriter

private TcpWriter tcpWriter

The writer thread responsible for writing the replies (output).

proxyService

private TcpProxyService proxyService

The TCP proxy service used to register and unregister this connection.

closeConnection

private boolean closeConnection

identity

private Identity identity

creationDate

private Date creationDate

Constructor Detail

TcpConnection

public TcpConnection(IOControl ioctrl,
                     ReliableConnectionContext ctx,
                     AgentId proxyId,
                     TcpProxyService proxyService,
                     Identity identity)

Creates a new TCP connection.

Parameters:

ioctrl -

ctx -

proxyId -

proxyService - the TCP proxy service

identity -

Method Detail

getMBeanName

private String getMBeanName()

getProxyId

public final AgentId getProxyId()

getKey

public final int getKey()

start

void start()
    throws Exception

Starts the connection reader and writer threads.

Throws:

Exception

close

public void close()

Stops the connection reader and writer threads. Closes the socket.

Specified by:

close in interface ProxyMessageSender

Specified by:

close in interface TcpConnectionMBean

getUserName

public String getUserName()

Description copied from interface: TcpConnectionMBean

Gets connected user's name.

Specified by:

getUserName in interface TcpConnectionMBean

Returns:

the name of the connected user.

getAddress

public String getAddress()

Description copied from interface: TcpConnectionMBean

Gets the socket address used by the connection.

Specified by:

getAddress in interface TcpConnectionMBean

Returns:

the connection's socket address.

getCreationDate

public Date getCreationDate()

Description copied from interface: TcpConnectionMBean

Gets connection creation date.

Specified by:

getCreationDate in interface TcpConnectionMBean

Returns:

the date of creation of the connection.

getReceivedCount

public long getReceivedCount()

Description copied from interface: TcpConnectionMBean

Gets the number of replies received on the connection.

Specified by:

getReceivedCount in interface TcpConnectionMBean

Returns:

the number of replies received on the connection.

getSentCount

public long getSentCount()

Description copied from interface: TcpConnectionMBean

Gets the number of requests sent on the connection.

Specified by:

getSentCount in interface TcpConnectionMBean

Returns:

the number of requests sent on the connection.

getAckedQueueSize

public int getAckedQueueSize()

Description copied from interface: TcpConnectionMBean

Gets the AckedQueue size.

Specified by:

getAckedQueueSize in interface TcpConnectionMBean

Returns:

the size of AckedQueue.

getQueueWorkerSize

public int getQueueWorkerSize()

Description copied from interface: TcpConnectionMBean

Gets the QueueWorker size.

Specified by:

getQueueWorkerSize in interface TcpConnectionMBean

Returns:

the size of QueueWorker.

getReaderQueueSize

public int getReaderQueueSize()

Description copied from interface: TcpConnectionMBean

Gets the ReaderQueue size.

Specified by:

getReaderQueueSize in interface TcpConnectionMBean

Returns:

the size of ReaderQueue.

send

public void send(ProxyMessage msg)
          throws Exception

Description copied from interface: ProxyMessageSender

Sends a message to the client.

Specified by:

send in interface ProxyMessageSender

Parameters:

msg - the message to be sent

Throws:

Exception - if an error occurs

isExecutor

public boolean isExecutor()

Description copied from interface: ProxyMessageSender

States whether executing a task is allowed.

Specified by:

isExecutor in interface ProxyMessageSender

Returns:

true if executing a task is allowed; false otherwise.

execute

public void execute(Runnable runnable)

Description copied from interface: ProxyMessageSender

Executes a task.

Specified by:

execute in interface ProxyMessageSender

Parameters:

runnable - task to be executed