Class TcpWriter
- java.lang.Object
-
- fr.dyade.aaa.common.Daemon
-
- org.objectweb.joram.mom.proxies.tcp.TcpWriter
-
-
Field Summary
Fields Modifier and Type Field Description private static booleanDEBUGprivate IOControlioctrlprivate static Loggerloggerprivate AckedQueuereplyQueueprivate TcpConnectiontcpConnectionThe TCP connection that started this writer.
-
Constructor Summary
Constructors Constructor Description TcpWriter(IOControl ioctrl, AckedQueue replyQueue, TcpConnection tcpConnection)Creates a new writer.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected voidclose()Releases any resources attached to this daemon.private voidhandleMessage(ProxyMessage msg)voidrun()protected voidshutdown()Interrupts a thread that waits for long periods.-
Methods inherited from class fr.dyade.aaa.common.Daemon
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, start, stop, toString
-
-
-
-
Field Detail
-
logger
private static final Logger logger
-
DEBUG
private static final boolean DEBUG
-
tcpConnection
private TcpConnection tcpConnection
The TCP connection that started this writer.
-
ioctrl
private IOControl ioctrl
-
replyQueue
private AckedQueue replyQueue
-
-
Constructor Detail
-
TcpWriter
public TcpWriter(IOControl ioctrl, AckedQueue replyQueue, TcpConnection tcpConnection)
Creates a new writer.
-
-
Method Detail
-
handleMessage
private void handleMessage(ProxyMessage msg) throws Exception
- Throws:
Exception
-
run
public void run()
-
shutdown
protected void shutdown()
Description copied from class:DaemonInterrupts a thread that waits for long periods. In some cases, we must use application specific tricks. For example, if a thread is waiting on a known socket, we have to close the socket to cause the thread to return immediately. Unfortunately, there really isn't any technique that works in general.
-
-