Class ClientStats.SubscriptionStats

java.lang.Object
org.mqtt4j.hato.ClientStats.SubscriptionStats
Enclosing class:
ClientStats
public static final class ClientStats.SubscriptionStats extends Object
The values of one subscription.

  • Method Details

    • subscription

      public Subscription subscription()
      Returns the subscription's handle.
      Returns:
      the subscription's handle

    • filter

      public TopicFilter filter()
      Returns the subscription's filter.
      Returns:
      the subscription's filter

    • waiting

      public long waiting()
      Returns the number of deliveries that wait for a handler, an acceptor, or a receiver.
      Returns:
      the number of deliveries that wait for a handler, an acceptor, or a receiver

    • running

      public long running()
      Returns the number of deliveries that a handler or a hand-off acceptor is processing.
      Returns:
      the number of deliveries that a handler or a hand-off acceptor is processing

    • awaitingAck

      public long awaitingAck()
      Returns the number of deliveries that a handler, an acceptor, or a receiver has processed, and whose MqttDelivery.ack() has not been called yet.
      Returns:
      the number of deliveries that a handler, an acceptor, or a receiver has processed, and whose MqttDelivery.ack() has not been called yet

    • bufferCapacity

      public int bufferCapacity()
      Returns the subscription's buffer capacity.
      Returns:
      the subscription's buffer capacity

    • dropped

      public Map<ClientStats.DropReason, Long> dropped()
      Returns lifetime counts of the subscription's deliveries that left it unprocessed, by reason.
      Returns:
      lifetime counts of the subscription's deliveries that left it unprocessed, by reason