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

java.lang.Object
  fr.dyade.aaa.util.Daemon
      org.objectweb.joram.client.jms.Driver
          org.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