class PacketQueue extends Object implements SendMessageStatusListener, Closeable
MessageOutputStream -> ConnectionDataReceiver -> Connection -> PacketQueue -> I2PSession
STATUS_CANCELLED| Constructor and Description |
|---|
PacketQueue(I2PAppContext context,
SimpleTimer2 timer)PacketQueue. |
| Modifier and Type | Method and 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 Closeableclose in interface AutoCloseablepublic boolean enqueue(PacketLocal packet)
packet - the packetpublic 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.