Closeable, AutoCloseable, SendMessageStatusListenerclass PacketQueue extends Object implements SendMessageStatusListener, Closeable
MessageOutputStream -> ConnectionDataReceiver -> Connection -> PacketQueue -> I2PSession
STATUS_CANCELLED| Constructor | Description |
|---|---|
PacketQueue(I2PAppContext context,
SimpleTimer2 timer) |
| Modifier and Type | Method | Description |
|---|---|---|
void |
close() |
Cannot be restarted.
|
boolean |
enqueue(PacketLocal packet) |
Add a new packet to be sent out ASAP.
|
void |
messageStatus(I2PSession session,
long msgId,
int status) |
SendMessageStatusListener interface
Tell the client of an update in the send status for a message
previously sent with I2PSession.sendMessage().
|
public PacketQueue(I2PAppContext context, SimpleTimer2 timer)
public void close()
close in interface AutoCloseableclose in interface Closeablepublic boolean enqueue(PacketLocal packet)
public void messageStatus(I2PSession session, long msgId, int status)
messageStatus in interface SendMessageStatusListenersession - session notifyingmsgId - message number returned from a previous sendMessage() callstatus - of the message, as defined in MessageStatusMessage and this class.