Constructor Detail

• I2CPMessageProducer

  public I2CPMessageProducer(I2PAppContext context)

  I2CPMessageProducer.

Method Detail

• connect

  public void connect(I2PSessionImpl session)
               throws I2PSessionException

  Connect to the server.

  Throws:

  I2PSessionException

• createLeaseSet

  public void createLeaseSet(I2PSessionImpl session,
                             LeaseSet leaseSet,
                             SigningPrivateKey signingPriv,
                             List<PrivateKey> privs)
                      throws I2PSessionException

  Send a CreateLeaseSet message.

  Throws:

  I2PSessionException

• disconnect

  public void disconnect(I2PSessionImpl session)
                  throws I2PSessionException

  Disconnect from the server.

  Throws:

  I2PSessionException

• reportAbuse

  public void reportAbuse(I2PSessionImpl session,
                          int msgId,
                          int severity)
                   throws I2PSessionException

  Send an abuse report.

  Throws:

  I2PSessionException

• sendMessage

  public void sendMessage(I2PSessionImpl session,
                          Destination dest,
                          long nonce,
                          byte[] payload,
                          long expires,
                          int flags)
                   throws I2PSessionException

  Send an I2CP message.

  Throws:

  I2PSessionException

• sendMessage

  public void sendMessage(I2PSessionImpl session,
                          Destination dest,
                          long nonce,
                          byte[] payload,
                          SendMessageOptions options)
                   throws I2PSessionException

  Send an I2CP message.

  Throws:

  I2PSessionException

• sendMessage

  public void sendMessage(I2PSessionImpl session,
                          Destination dest,
                          long nonce,
                          byte[] payload,
                          SessionTag tag,
                          SessionKey key,
                          Set<SessionTag> tags,
                          SessionKey newKey,
                          long expires)
                   throws I2PSessionException

  Send an I2CP message.

  Throws:

  I2PSessionException

• updateBandwidth

  public void updateBandwidth(I2PSessionImpl session)

  Update bandwidth limits.

• updateTunnels

  public void updateTunnels(I2PSessionImpl session,
                            int tunnels)
                     throws I2PSessionException

  Update the tunnel count and settings.

  Throws:

  I2PSessionException