class QueuedClientConnectionRunner extends ClientConnectionRunner
_context, _log, _manager, _reader
Constructor and Description |
---|
QueuedClientConnectionRunner(RouterContext context,
ClientManager manager,
I2CPMessageQueue queue)
Create a new runner with the given queues
|
Modifier and Type | Method and Description |
---|---|
(package private) void |
doSend(I2CPMessage msg)
Actually send the I2CPMessage to the client.
|
String |
getClientVersion()
The client version.
|
void |
setClientVersion(String version)
Does nothing.
|
void |
startRunning()
Starts the reader thread.
|
void |
stopRunning()
Calls super() to stop the reader, and sends a poison message to the client.
|
(package private) void |
writeMessage(I2CPMessage msg)
In super(), doSend queues it to the writer thread and
the writer thread calls writeMessage() to write to the output stream.
|
ackSendMessage, createListener, disconnectClient, disconnectClient, disconnected, distributeMessage, failLeaseRequest, getConfig, getConfig, getDestHash, getDestHash, getDestination, getDestinations, getIsDead, getLeaseRequest, getLeaseSet, getNextMessageId, getPayload, getPrimaryConfig, getSessionId, getSessionIds, getSessionKeyManager, isDead, leaseSetCreated, receiveMessage, receiveMessage, removePayload, removeSession, reportAbuse, requestLeaseSet, sessionEstablished, setPayload, setSessionId, updateMessageDeliveryStatus
public QueuedClientConnectionRunner(RouterContext context, ClientManager manager, I2CPMessageQueue queue)
public void startRunning()
startRunning
in class ClientConnectionRunner
public void stopRunning()
stopRunning
in class ClientConnectionRunner
void writeMessage(I2CPMessage msg)
writeMessage
in class ClientConnectionRunner
void doSend(I2CPMessage msg) throws I2CPMessageException
doSend
in class ClientConnectionRunner
I2CPMessageException
- if queue full or on other errorspublic void setClientVersion(String version)
setClientVersion
in class ClientConnectionRunner
public String getClientVersion()
getClientVersion
in class ClientConnectionRunner