Package net.i2p.client.streaming.impl

Class PacketQueue

java.lang.Object
net.i2p.client.streaming.impl.PacketQueue
All Implemented Interfaces:
Closeable, AutoCloseable, 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

  • Constructor Details

  • Method Details

    • close

      public void close()
      Cannot be restarted.
      Specified by:
      close in interface AutoCloseable
      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. This updates the acks. 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 notifying
      msgId - message number returned from a previous sendMessage() call
      status - of the message, as defined in MessageStatusMessage and this class.
      Since:
      0.9.14