class PacketQueue extends Object implements SendMessageStatusListener
MessageOutputStream -> ConnectionDataReceiver -> Connection -> PacketQueue -> I2PSession
STATUS_CANCELLED
Constructor and Description |
---|
PacketQueue(I2PAppContext context,
I2PSession session,
ConnectionManager mgr) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Cannot be restarted.
|
boolean |
enqueue(PacketLocal packet)
Add a new packet to be sent out ASAP
keys and tags disabled since dropped in I2PSession
|
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, I2PSession session, ConnectionManager mgr)
public void close()
public boolean enqueue(PacketLocal packet)
public void messageStatus(I2PSession session, long msgId, int status)
messageStatus
in interface SendMessageStatusListener
session
- session notifyingmsgId
- message number returned from a previous sendMessage() callstatus
- of the message, as defined in MessageStatusMessage and this class.