コンストラクタの詳細

• I2CPMessageQueueImpl

  public I2CPMessageQueueImpl​(java.util.concurrent.BlockingQueue<I2CPMessage> in,
                              java.util.concurrent.BlockingQueue<I2CPMessage> out)

メソッドの詳細

• offer

  public boolean offer​(I2CPMessage msg)

  Send a message, nonblocking

  定義:

  offer クラス内 I2CPMessageQueue

  戻り値:

  success (false if no space available)

• offer

  public boolean offer​(I2CPMessage msg,
                       long timeout)
                throws java.lang.InterruptedException

  Send a message, blocking.

  定義:

  offer クラス内 I2CPMessageQueue

  パラメータ:

  timeout - how long to wait for space (ms)

  戻り値:

  success (false if no space available or if timed out)

  例外:

  java.lang.InterruptedException

  導入されたバージョン:

  0.9.3

• poll

  public I2CPMessage poll​()

  Receive a message, nonblocking

  定義:

  poll クラス内 I2CPMessageQueue

  戻り値:

  message or null if none available

• put

  public void put​(I2CPMessage msg)
           throws java.lang.InterruptedException

  Send a message, blocking until space is available

  定義:

  put クラス内 I2CPMessageQueue

  例外:

  java.lang.InterruptedException

• take

  public I2CPMessage take​()
                   throws java.lang.InterruptedException

  Receive a message, blocking until one is available

  定義:

  take クラス内 I2CPMessageQueue

  戻り値:

  message

  例外:

  java.lang.InterruptedException