Package org.ow2.joram.jakarta.jms.tcp

Class ReliableTcpClient

java.lang.Object

org.ow2.joram.jakarta.jms.tcp.ReliableTcpClient

Direct Known Subclasses:

ReliableSSLTcpClient

public class ReliableTcpClient
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ReliableTcpClient.ServerAddress

Field Summary

Fields

Modifier and Type	Field	Description
private Vector<ReliableTcpClient.ServerAddress>	addresses
static String	CLOCK_SYNCHRO_THRESHOLD	Name of the property allowing to change the threshold of warning for the verification of the synchronization between the client and server clock.
private long	clockSynchroThreshold	Value of the threshold of warning for the verification of the synchronization between the client and server clock.
static int	CLOSE
static int	CONNECT
private ReliableTcpConnection	connection
private static boolean	DEBUG
protected Identity	identity
static int	INIT
protected int	key
private static Logger	logger
protected FactoryParameters	params
private boolean	reconnect	True if the client must try to reconnect in case of connection failure.
private int	reconnectTimeout	Time in ms during the client try to reconnect to the server.
private int	status
protected static String[]	statusNames
private Timer	timer

Constructor Summary

Constructors

Constructor	Description
ReliableTcpClient()

Method Summary

Modifier and Type	Method	Description
void	addServerAddress(String host, int port)
void	close()
void	connect()
void	connect(boolean reconnect)
protected Socket	createSocket(String hostname, int port)
private void	doConnect(String hostname, int port)
void	init(FactoryParameters params, Identity identity, boolean reconnect)
Object	receive()
private void	reconnect()
void	send(AbstractJmsMessage request)
private void	setStatus(int status)
void	setTimer(Timer timer)
void	stopReconnections()
private void	throwSecurityError(String info)
String	toString()
private void	waitForReconnection()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static final Logger logger

DEBUG

private static final boolean DEBUG

INIT

public static final int INIT

See Also:

Constant Field Values

CONNECT

public static final int CONNECT

See Also:

Constant Field Values

CLOSE

public static final int CLOSE

See Also:

Constant Field Values

statusNames

protected static final String[] statusNames

params

protected FactoryParameters params

identity

protected Identity identity

key

protected int key

connection

private ReliableTcpConnection connection

status

private volatile int status

addresses

private Vector<ReliableTcpClient.ServerAddress> addresses

reconnect

private boolean reconnect

True if the client must try to reconnect in case of connection failure. It depends of cnxPendingTimer on a "normal" TCP connection.

reconnectTimeout

private int reconnectTimeout

Time in ms during the client try to reconnect to the server. It depends of connectingTimer and cnxPendingTimer from the connection parameters.

timer

private Timer timer

CLOCK_SYNCHRO_THRESHOLD

public static final String CLOCK_SYNCHRO_THRESHOLD

Name of the property allowing to change the threshold of warning for the verification of the synchronization between the client and server clock. A warning is generated if there is more than this value in milliseconds between the two clocks.

By default the value is 1000 milliseconds.

See Also:

Constant Field Values

clockSynchroThreshold

private long clockSynchroThreshold

Value of the threshold of warning for the verification of the synchronization between the client and server clock. A warning is generated if there is more than this value in milliseconds between the two clocks.

By default the value is 1000 milliseconds.

Constructor Detail

ReliableTcpClient

public ReliableTcpClient()

Method Detail

setTimer

public void setTimer(Timer timer)

init

public void init(FactoryParameters params,
                 Identity identity,
                 boolean reconnect)

setStatus

private void setStatus(int status)

connect

public void connect()
             throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

connect

public void connect(boolean reconnect)
             throws jakarta.jms.JMSException

Throws:

jakarta.jms.JMSException

createSocket

protected Socket createSocket(String hostname,
                              int port)
                       throws Exception

Throws:

Exception

doConnect

private void doConnect(String hostname,
                       int port)
                throws Exception,
                       jakarta.jms.JMSException

Throws:

Exception

jakarta.jms.JMSException

throwSecurityError

private void throwSecurityError(String info)
                         throws jakarta.jms.JMSSecurityException

Throws:

jakarta.jms.JMSSecurityException

send

public void send(AbstractJmsMessage request)
          throws Exception

Throws:

Exception

receive

public Object receive()
               throws Exception

Throws:

Exception

waitForReconnection

private void waitForReconnection()
                          throws Exception

Throws:

Exception

reconnect

private void reconnect()
                throws Exception

Throws:

Exception

close

public void close()

addServerAddress

public void addServerAddress(String host,
                             int port)

toString

public String toString()

Overrides:

toString in class Object

stopReconnections

public void stopReconnections()