class QueuedClientConnectionRunner extends ClientConnectionRunner
_context, _log, _manager, _reader
コンストラクタ | 説明 |
---|---|
QueuedClientConnectionRunner(RouterContext context,
ClientManager manager,
I2CPMessageQueue queue) |
Create a new runner with the given queues
|
修飾子とタイプ | メソッド | 説明 |
---|---|---|
(package private) void |
doSend(I2CPMessage msg) |
Actually send the I2CPMessage to the client.
|
java.lang.String |
getClientVersion() |
The client version.
|
void |
setClientVersion(java.lang.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
クラス内 ClientConnectionRunner
public void stopRunning()
stopRunning
クラス内 ClientConnectionRunner
void writeMessage(I2CPMessage msg)
writeMessage
クラス内 ClientConnectionRunner
void doSend(I2CPMessage msg) throws I2CPMessageException
doSend
クラス内 ClientConnectionRunner
I2CPMessageException
- if queue full or on other errorspublic void setClientVersion(java.lang.String version)
setClientVersion
クラス内 ClientConnectionRunner
public java.lang.String getClientVersion()
getClientVersion
クラス内 ClientConnectionRunner