Package com.tangosol.net.topic

Interface Subscriber.Channel

All Known Implementing Classes:
Subscriber.Channel.EmptyChannel
Enclosing interface:
Subscriber<V>
public static interface Subscriber.Channel
A representation of a topic channel within subscriber.

  • Nested Class Summary

    Nested Classes
    Modifier and Type
    Interface
    Description
    static class 
    Subscriber.Channel.EmptyChannel
    A default empty channel implementation.

  • Method Summary

    Modifier and Type
    Method
    Description
    long
    getCommitCount()
    Return the number of completed commit requests.
    Position
    getFirstPolled()
    Returns the first position polled by this subscriber.
    long
    getFirstPolledTimestamp()
    Returns the timestamp when the first element was polled by this subscriber.
    Position
    getHead()
    Returns the current head position for the channel.
    int
    getId()
    Returns the identifier for this channel.
    Position
    getLastCommit()
    Returns the last position committed by this subscriber.
    Position
    getLastPolled()
    Returns the last position polled by this subscriber.
    long
    getLastPolledTimestamp()
    Returns the timestamp when the last element was polled by this subscriber.
    Position
    getLastReceived()
    Returns the last position received by this subscriber.
    int
    getOwnedCode()
    Returns a numeric representation of if the channel is owned by this subscriber where 1 represents true and 0 represents false.
    long
    getPolls()
    Returns the number of elements polled by this subscriber.
    long
    getReceiveCount()
    Return the number of completed receive requests.
    long
    getReceived()
    Return the number of completed receive requests.
    double
    getReceivedFifteenMinuteRate()
    Return the fifteen-minute rate of completed receive requests.
    double
    getReceivedFiveMinuteRate()
    Return the five-minute rate of completed receive requests.
    double
    getReceivedMeanRate()
    Return the mean rate of completed receive requests.
    double
    getReceivedOneMinuteRate()
    Return the one-minute rate of completed receive requests.
    boolean
    isEmpty()
    Returns true if the channel is empty.
    boolean
    isOwned()
    Returns true if the channel is owned by this subscriber.

  • Method Details

    • 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