Package com.tangosol.net.topic
Interface Subscriber.Channel
-
- All Known Implementing Classes:
Subscriber.Channel.EmptyChannel
- Enclosing interface:
- Subscriber<V>
public static interface Subscriber.ChannelA representation of a topic channel within subscriber.
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static classSubscriber.Channel.EmptyChannelA default empty channel implementation.
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longgetCommitCount()Return the number of completed commit requests.PositiongetFirstPolled()Returns the first position polled by this subscriber.longgetFirstPolledTimestamp()Returns the timestamp when the first element was polled by this subscriber.PositiongetHead()Returns the current head position for the channel.intgetId()Returns the identifier for this channel.PositiongetLastCommit()Returns the last position committed by this subscriber.PositiongetLastPolled()Returns the last position polled by this subscriber.longgetLastPolledTimestamp()Returns the timestamp when the last element was polled by this subscriber.PositiongetLastReceived()Returns the last position received by this subscriber.intgetOwnedCode()Returns a numeric representation of if the channel is owned by this subscriber where1represents true and0represents false.longgetPolls()Returns the number of elements polled by this subscriber.longgetReceiveCount()Return the number of completed receive requests.longgetReceived()Return the number of completed receive requests.doublegetReceivedFifteenMinuteRate()Return the fifteen-minute rate of completed receive requests.doublegetReceivedFiveMinuteRate()Return the five-minute rate of completed receive requests.doublegetReceivedMeanRate()Return the mean rate of completed receive requests.doublegetReceivedOneMinuteRate()Return the one-minute rate of completed receive requests.booleanisEmpty()Returnstrueif the channel is empty.booleanisOwned()Returnstrueif the channel is owned by this subscriber.
-
-
-
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()
Returnstrueif the channel is empty.- Returns:
trueif the channel is empty
-
isOwned
boolean isOwned()
Returnstrueif the channel is owned by this subscriber.- Returns:
trueif the channel is owned by this subscriber
-
getOwnedCode
int getOwnedCode()
Returns a numeric representation of if the channel is owned by this subscriber where1represents true and0represents false.- Returns:
- a numeric representation of if the channel is owned by this subscriber
where
1represents true and0represents 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
-
-