Class 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

    • Method Detail

      • 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