Package org.apache.pulsar.common.policies.data

Interface DrainingHash

public interface DrainingHash
Contains information about a draining hash in a Key_Shared subscription.
See Also:

  • Method Summary Link icon

    Modifier and Type
    Method
    Description
    int
    getBlockedAttempts()
    Get the number of times the hash has blocked an attempted delivery of a message.
    int
    getHash()
    Get the sticky key hash value of the draining hash.
    int
    getUnackMsgs()
    Get number of unacknowledged messages for the draining hash.

  • Method Details Link icon

    • getHash Link icon

      int getHash()
      Get the sticky key hash value of the draining hash.
      Returns:
      the sticky hash value

    • getUnackMsgs Link icon

      int getUnackMsgs()
      Get number of unacknowledged messages for the draining hash.
      Returns:
      number of unacknowledged messages

    • getBlockedAttempts Link icon

      int getBlockedAttempts()
      Get the number of times the hash has blocked an attempted delivery of a message.
      Returns:
      number of times the hash has blocked an attempted delivery of a message