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

Class TcpRequestChannel

java.lang.Object

org.ow2.joram.jakarta.jms.tcp.TcpRequestChannel

All Implemented Interfaces:

RequestChannel

public class TcpRequestChannel
extends Object
implements RequestChannel

A TcpConnection links a Joram client and a Joram platform with a TCP socket.

Requests and replies travel through the socket after serialization.

Field Summary

Fields

Modifier and Type	Field	Description
private static boolean	DEBUG
private Identity	identity
private static Logger	logger
private ReliableTcpClient	tcpClient

Constructor Summary

Constructors

Constructor	Description
TcpRequestChannel(FactoryParameters params, Identity identity)	Creates a TcpConnection instance.
TcpRequestChannel(FactoryParameters params, Identity identity, String reliableClass)	Creates a TcpConnection instance.

Method Summary

Modifier and Type	Method	Description
void	close()	Closes the TCP connection.
void	closing()
void	connect()
Identity	getIdentity()
AbstractJmsReply	receive()
void	send(AbstractJmsRequest request)	Sending a JMS request through the TCP connection.
void	setTimer(Timer timer)
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

logger

private static Logger logger

DEBUG

private static final boolean DEBUG

tcpClient

private ReliableTcpClient tcpClient

identity

private Identity identity

Constructor Detail

TcpRequestChannel

public TcpRequestChannel(FactoryParameters params,
                         Identity identity)
                  throws jakarta.jms.JMSException

Creates a TcpConnection instance.

Parameters:

params - Factory parameters.

identity -

Throws:

jakarta.jms.JMSSecurityException - If the user identification is incorrect.

jakarta.jms.IllegalStateException - If the server is not reachable.

jakarta.jms.JMSException

TcpRequestChannel

public TcpRequestChannel(FactoryParameters params,
                         Identity identity,
                         String reliableClass)
                  throws jakarta.jms.JMSException

Creates a TcpConnection instance.

Parameters:

params - Factory parameters.

identity -

reliableClass - reliable class name.

Throws:

jakarta.jms.JMSSecurityException - If the user identification is incorrect.

jakarta.jms.IllegalStateException - If the server is not reachable.

jakarta.jms.JMSException

Method Detail

setTimer

public void setTimer(Timer timer)

Specified by:

setTimer in interface RequestChannel

connect

public void connect()
             throws Exception

Specified by:

connect in interface RequestChannel

Throws:

Exception

send

public void send(AbstractJmsRequest request)
          throws Exception

Sending a JMS request through the TCP connection.

Specified by:

send in interface RequestChannel

Throws:

jakarta.jms.IllegalStateException - If the connection is broken.

Exception

receive

public AbstractJmsReply receive()
                         throws Exception

Specified by:

receive in interface RequestChannel

Throws:

Exception

close

public void close()

Closes the TCP connection.

Specified by:

close in interface RequestChannel

toString

public String toString()

Overrides:

toString in class Object

closing

public void closing()

Specified by:

closing in interface RequestChannel

getIdentity

public Identity getIdentity()

Specified by:

getIdentity in interface RequestChannel