org.objectweb.joram.client.jms.ha.tcp
Class HATcpRequestChannel
java.lang.Object
org.objectweb.joram.client.jms.ha.tcp.HATcpRequestChannel
- All Implemented Interfaces:
- RequestChannel
public class HATcpRequestChannel
- extends java.lang.Object
- implements RequestChannel
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
tcpClient
private ReliableTcpClient tcpClient
HATcpRequestChannel
public HATcpRequestChannel(java.lang.String url,
FactoryParameters params,
Identity identity)
throws javax.jms.JMSException
- Creates a
HATcpConnection
instance.
- Parameters:
params
- Factory parameters.identity
-
- Throws:
javax.jms.JMSSecurityException
- If the user identification is incorrect.
java.lang.IllegalStateException
- If the server is not reachable.
javax.jms.JMSException
HATcpRequestChannel
public HATcpRequestChannel()
HATcpRequestChannel
public HATcpRequestChannel(java.lang.String url,
FactoryParameters params,
Identity identity,
java.lang.String reliableClass)
throws javax.jms.JMSException
- Creates a
HATcpConnection
instance.
- Parameters:
params
- Factory parameters.identity
- reliableClass
- reliable class name.
- Throws:
javax.jms.JMSSecurityException
- If the user identification is incorrect.
java.lang.IllegalStateException
- If the server is not reachable.
javax.jms.JMSException
setTimer
public void setTimer(java.util.Timer timer)
- Specified by:
setTimer
in interface RequestChannel
connect
public void connect()
throws java.lang.Exception
- Specified by:
connect
in interface RequestChannel
- Throws:
java.lang.Exception
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
closing
public void closing()
- Specified by:
closing
in interface RequestChannel
Copyright © 2010 ScalAgent D.T.. All Rights Reserved.