org.objectweb.joram.client.jms.ha.tcp
Class HATcpConnection

java.lang.Object
  org.objectweb.joram.client.jms.ha.tcp.HATcpConnection

All Implemented Interfaces:

RequestChannel

public class HATcpConnection

extends java.lang.Object

implements RequestChannel

Constructor Summary

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

HATcpConnection(java.lang.String url, FactoryParameters params, java.lang.String name, java.lang.String password, java.lang.String reliableClass)
Creates a HATcpConnection instance.

Method Summary

void	close() Closes the TCP connection.
AbstractJmsReply	receive()
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

HATcpConnection

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

Creates a HATcpConnection instance.

Parameters:

params - Factory parameters.

name - Name of user.

password - Password of user.

Throws:

JMSSecurityException - If the user identification is incorrrect.

java.lang.IllegalStateException - If the server is not reachable.

javax.jms.JMSException

HATcpConnection

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

Creates a HATcpConnection instance.

Parameters:

params - Factory parameters.

name - Name of user.

password - Password of user.

reliableClass - reliable class name.

Throws:

JMSSecurityException - If the user identification is incorrrect.

java.lang.IllegalStateException - If the server is not reachable.

javax.jms.JMSException

Method Detail

send

public void send(AbstractJmsRequest request)
          throws java.lang.Exception

Sending a JMS request through the TCP connection.

Specified by:

send in interface RequestChannel

Throws:

java.lang.Exception

receive

public AbstractJmsReply receive()
                         throws java.lang.Exception

Specified by:

receive in interface RequestChannel

Throws:

java.lang.Exception

close

public void close()

Closes the TCP connection.

Specified by:

close in interface RequestChannel