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
All Methods Instance Methods Abstract Methods 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 where1
represents true and0
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()
Returnstrue
if the channel is empty.boolean
isOwned()
Returnstrue
if 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()
Returnstrue
if the channel is empty.- Returns:
true
if the channel is empty
-
isOwned
boolean isOwned()
Returnstrue
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 where1
represents true and0
represents false.- Returns:
- a numeric representation of if the channel is owned by this subscriber
where
1
represents true and0
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
-
-