Modifier and Type | Field and Description |
---|---|
private IOControl |
ioctrl |
static org.objectweb.util.monolog.api.Logger |
logger
logger
|
private AckedQueue |
replyQueue |
private TcpConnection |
tcpConnection
The TCP connection that started this writer.
|
Constructor and Description |
---|
TcpWriter(IOControl ioctrl,
AckedQueue replyQueue,
TcpConnection tcpConnection)
Creates a new writer.
|
Modifier and Type | Method and Description |
---|---|
protected void |
close()
Releases any resources attached to this daemon.
|
private void |
handleMessage(ProxyMessage msg) |
void |
run() |
protected void |
shutdown()
Interrupts a thread that waits for long periods.
|
finish, getName, interrupt, isCurrentThread, isRunning, setDaemon, setName, setPriority, setThreadGroup, start, stop, toString
public static org.objectweb.util.monolog.api.Logger logger
private TcpConnection tcpConnection
private IOControl ioctrl
private AckedQueue replyQueue
public TcpWriter(IOControl ioctrl, AckedQueue replyQueue, TcpConnection tcpConnection)
private void handleMessage(ProxyMessage msg) throws Exception
Exception
public void run()
protected void shutdown()
Daemon
Copyright © 2020 ScalAgent D.T.. All rights reserved.