net.i2p.client.streaming.impl
Class PacketQueue
java.lang.Object
net.i2p.client.streaming.impl.PacketQueue
- All Implemented Interfaces:
- Closeable, SendMessageStatusListener
class PacketQueue
- extends Object
- implements SendMessageStatusListener, Closeable
Queue out packets to be sent through the session.
Well, thats the theory at least... in practice we just
send them immediately with no blocking, since the
mode=bestEffort doesnt block in the SDK.
MessageOutputStream -> ConnectionDataReceiver -> Connection -> PacketQueue -> I2PSession
Method Summary |
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(). |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
PacketQueue
public PacketQueue(I2PAppContext context,
SimpleTimer2 timer)
close
public void close()
- Cannot be restarted.
- Specified by:
close
in interface Closeable
- Since:
- 0.9.14
enqueue
public boolean enqueue(PacketLocal packet)
- Add a new packet to be sent out ASAP
keys and tags disabled since dropped in I2PSession
- Returns:
- true if sent
messageStatus
public 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().
Multiple calls for a single message ID are possible.
- Specified by:
messageStatus
in interface SendMessageStatusListener
- Parameters:
session
- session notifyingmsgId
- message number returned from a previous sendMessage() callstatus
- of the message, as defined in MessageStatusMessage and this class.- Since:
- 0.9.14