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

    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

    • getHash

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

    • getUnackMsgs

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

    • getBlockedAttempts

      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