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, updateMessageDeliveryStatuspublic QueuedClientConnectionRunner(RouterContext context, ClientManager manager, I2CPMessageQueue queue)
public void startRunning()
startRunning クラス内 ClientConnectionRunnerpublic void stopRunning()
stopRunning クラス内 ClientConnectionRunnervoid writeMessage(I2CPMessage msg)
writeMessage クラス内 ClientConnectionRunnervoid doSend(I2CPMessage msg) throws I2CPMessageException
doSend クラス内 ClientConnectionRunnerI2CPMessageException - if queue full or on other errorspublic void setClientVersion(java.lang.String version)
setClientVersion クラス内 ClientConnectionRunnerpublic java.lang.String getClientVersion()
getClientVersion クラス内 ClientConnectionRunner