Joram ${version}

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

java.lang.Object
  extended byorg.objectweb.joram.client.jms.tcp.ReliableTcpClient
Direct Known Subclasses:
ReliableSSLTcpClient

public class ReliableTcpClient
extends java.lang.Object


Field Summary
static int CLOSE
           
static int CONNECT
           
static int ERROR
           
static int INIT
           
static java.lang.String[] statusNames
           
 
Constructor Summary
ReliableTcpClient()
           
 
Method Summary
 void addServerAddress(java.lang.String host, int port)
           
 void close()
           
 void connect()
           
 void connect(boolean reconnect)
           
protected  java.net.Socket createSocket(java.lang.String hostName, int port)
           
 void init(FactoryParameters params, java.lang.String name, java.lang.String password, boolean reconnect)
           
 java.lang.Object receive()
           
 void send(java.lang.Object request)
           
 java.lang.String toString()
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Field Detail

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

ERROR

public static final int ERROR
See Also:
Constant Field Values

statusNames

public static final java.lang.String[] statusNames
Constructor Detail

ReliableTcpClient

public ReliableTcpClient()
Method Detail

init

public void init(FactoryParameters params,
                 java.lang.String name,
                 java.lang.String password,
                 boolean reconnect)

connect

public void connect()
             throws javax.jms.JMSException
Throws:
javax.jms.JMSException

connect

public void connect(boolean reconnect)
             throws javax.jms.JMSException
Throws:
javax.jms.JMSException

createSocket

protected java.net.Socket createSocket(java.lang.String hostName,
                                       int port)
                                throws java.lang.Exception
Throws:
java.lang.Exception

send

public void send(java.lang.Object request)
          throws java.lang.Exception
Throws:
java.lang.Exception

receive

public java.lang.Object receive()
                         throws java.lang.Exception
Throws:
java.lang.Exception

close

public void close()

addServerAddress

public void addServerAddress(java.lang.String host,
                             int port)

toString

public java.lang.String toString()

Joram ${version}

Copyright © 2005 Scalagent - All rights reserved