org.objectweb.joram.client.jms.tcp
Class TcpConnection

java.lang.Object
  org.objectweb.joram.client.jms.tcp.TcpConnection

All Implemented Interfaces:

ConnectionItf

public class TcpConnection

extends java.lang.Object

implements ConnectionItf

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

Requests and replies travel through the socket after serialization.

Constructor Summary

TcpConnection(FactoryParameters params, java.lang.String name, java.lang.String password)
Creates a TcpConnection instance.

Method Summary

void	close() Closes the TCP connection.
Driver	createDriver(Connection cnx) Creates a driver for the connection.
void	send(AbstractJmsRequest request) Sending a JMS request through the TCP connection.

Methods inherited from class java.lang.Object

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

Constructor Detail

TcpConnection

public TcpConnection(FactoryParameters params,
                     java.lang.String name,
                     java.lang.String password)
              throws javax.jms.JMSException

Creates a TcpConnection instance.

Parameters:

params - Factory parameters.

name - Name of user.

password - Password of user.

Throws:

javax.jms.JMSSecurityException - If the user identification is incorrrect.

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

javax.jms.JMSException

Method Detail

createDriver

public Driver createDriver(Connection cnx)

Creates a driver for the connection.

Specified by:

createDriver in interface ConnectionItf

Parameters:

cnx - The calling Connection instance.

send

public void send(AbstractJmsRequest request)
          throws javax.jms.IllegalStateException

Sending a JMS request through the TCP connection.

Specified by:

send in interface ConnectionItf

Throws:

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

close

public void close()

Closes the TCP connection.

Specified by:

close in interface ConnectionItf