Package net.i2p.router.transport.udp

Interface MessageQueue

All Known Implementing Classes:
TimedWeightedPriorityMessageQueue
interface MessageQueue
Base queue for messages not yet packetized

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    add(OutNetMessage message)
    Add on a new message to the queue
    OutNetMessage
    getNext(long blockUntil)
    Get the next message, blocking until one is found or the expiration reached.

  • Method Details

    • getNext

      OutNetMessage getNext(long blockUntil)
      Get the next message, blocking until one is found or the expiration reached.
      Parameters:
      blockUntil - expiration, or -1 if indefinite

    • add

      void add(OutNetMessage message)
      Add on a new message to the queue