Interface Subscriber.Channel

    • Method Detail

      • getId

        int getId()
        Returns the identifier for this channel.
        Returns:
        the identifier for this channel
      • getHead

        Position getHead()
        Returns the current head position for the channel.
        Returns:
        the current head position for the channel
      • getLastCommit

        Position getLastCommit()
        Returns the last position committed by this subscriber.
        Returns:
        the last position committed by this subscriber
      • getCommitCount

        long getCommitCount()
        Return the number of completed commit requests.
        Returns:
        the number of completed commit requests
      • getLastReceived

        Position getLastReceived()
        Returns the last position received by this subscriber.
        Returns:
        the last position received by this subscriber
      • getReceiveCount

        long getReceiveCount()
        Return the number of completed receive requests.
        Returns:
        the number of completed receive requests
      • getPolls

        long getPolls()
        Returns the number of elements polled by this subscriber.
        Returns:
        the number of elements polled by this subscriber
      • getFirstPolled

        Position getFirstPolled()
        Returns the first position polled by this subscriber.
        Returns:
        the first position polled by this subscriber
      • getFirstPolledTimestamp

        long getFirstPolledTimestamp()
        Returns the timestamp when the first element was polled by this subscriber.
        Returns:
        the timestamp when the first element was polled by this subscriber
      • getLastPolled

        Position getLastPolled()
        Returns the last position polled by this subscriber.
        Returns:
        the last position polled by this subscriber
      • getLastPolledTimestamp

        long getLastPolledTimestamp()
        Returns the timestamp when the last element was polled by this subscriber.
        Returns:
        the timestamp when the last element was polled by this subscriber
      • isEmpty

        boolean isEmpty()
        Returns true if the channel is empty.
        Returns:
        true if the channel is empty
      • isOwned

        boolean isOwned()
        Returns true if the channel is owned by this subscriber.
        Returns:
        true if the channel is owned by this subscriber
      • getOwnedCode

        int getOwnedCode()
        Returns a numeric representation of if the channel is owned by this subscriber where 1 represents true and 0 represents false.
        Returns:
        a numeric representation of if the channel is owned by this subscriber where 1 represents true and 0 represents false
      • getReceived

        long getReceived()
        Return the number of completed receive requests.
        Returns:
        the number of completed receive requests
      • getReceivedMeanRate

        double getReceivedMeanRate()
        Return the mean rate of completed receive requests.
        Returns:
        the mean rate of completed receive requests
      • getReceivedOneMinuteRate

        double getReceivedOneMinuteRate()
        Return the one-minute rate of completed receive requests.
        Returns:
        the one-minute rate of completed receive requests
      • getReceivedFiveMinuteRate

        double getReceivedFiveMinuteRate()
        Return the five-minute rate of completed receive requests.
        Returns:
        the five-minute rate of completed receive requests
      • getReceivedFifteenMinuteRate

        double getReceivedFifteenMinuteRate()
        Return the fifteen-minute rate of completed receive requests.
        Returns:
        the fifteen-minute rate of completed receive requests