Class ClientStats.Subscribing

java.lang.Object
org.mqtt4j.hato.ClientStats.Subscribing
Enclosing class:
ClientStats
public static final class ClientStats.Subscribing extends Object
The subscription registrations and delivery lanes, in total.

  • Method Details

    • registrations

      public ClientStats.Usage registrations()
      Returns the registrations that the client has processed, against MqttClientBuilder.maxSubscriptions(int): the sum of established(), pending(), and removing().
      Returns:
      the registrations that the client has processed, against MqttClientBuilder.maxSubscriptions(int): the sum of established(), pending(), and removing()

    • established

      public long established()
      Returns the number of registrations that the broker has granted.
      Returns:
      the number of registrations that the broker has granted

    • pending

      public long pending()
      Returns the number of registrations that wait for a connection or for the broker's SUBACK.
      Returns:
      the number of registrations that wait for a connection or for the broker's SUBACK

    • removing

      public long removing()
      Returns the number of registrations whose removal waits for the broker's UNSUBACK or for a connection that discards the session.
      Returns:
      the number of registrations whose removal waits for the broker's UNSUBACK or for a connection that discards the session

    • lanes

      public ClientStats.Usage lanes()
      Returns the delivery lanes, one for each subscription, including the lanes of stopped subscriptions whose handlers have not returned, against MqttClientBuilder.maxSubscriptions(int). These are not the application lanes that DeliveryOptions.lanes(java.util.function.Function) chooses.
      Returns:
      the delivery lanes, one for each subscription, including the lanes of stopped subscriptions whose handlers have not returned, against MqttClientBuilder.maxSubscriptions(int)