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

java.lang.Object
  extended byfr.dyade.aaa.util.Daemon
      extended byorg.objectweb.joram.client.jms.Driver
          extended byorg.objectweb.joram.client.jms.tcp.TcpDriver
All Implemented Interfaces:
java.lang.Runnable

public class TcpDriver
extends Driver

A TcpDriver gets server deliveries coming through a TCP socket.


Field Summary
 
Fields inherited from class fr.dyade.aaa.util.Daemon
canStop, group, logmon, priority, running, thread
 
Constructor Summary
TcpDriver(Connection cnx, ReliableTcpClient tcpClient)
          Constructs a TcpDriver daemon.
 
Method Summary
protected  AbstractJmsReply getDelivery()
          Returns an AbstractJmsReply delivered by the connected server.
 void shutdown()
          Shuts down the driver.
 
Methods inherited from class org.objectweb.joram.client.jms.Driver
close, run, toString
 
Methods inherited from class fr.dyade.aaa.util.Daemon
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setPriority, setThreadGroup, start, stop
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
 

Constructor Detail

TcpDriver

public TcpDriver(Connection cnx,
                 ReliableTcpClient tcpClient)
Constructs a TcpDriver daemon.

Parameters:
cnx - The connection the driver belongs to.
Method Detail

getDelivery

protected AbstractJmsReply getDelivery()
                                throws java.lang.Exception
Returns an AbstractJmsReply delivered by the connected server.

Specified by:
getDelivery in class Driver
Throws:
java.io.IOException - If the connection failed.
java.lang.ClassNotFoundException - If the reply is invalid.
java.lang.Exception - If a problem occurs when getting the delivery.

shutdown

public void shutdown()
Shuts down the driver.

Specified by:
shutdown in class Driver


Copyright ? 2004 Scalagent - All rights reserved