Package com.tangosol.net.topic

Class Subscriber.Channel.EmptyChannel

java.lang.Object

com.tangosol.net.topic.Subscriber.Channel.EmptyChannel

All Implemented Interfaces:

Subscriber.Channel

Enclosing interface:

Subscriber.Channel

public static class Subscriber.Channel.EmptyChannel
extends Object
implements Subscriber.Channel

A default empty channel implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface com.tangosol.net.topic.Subscriber.Channel

Subscriber.Channel.EmptyChannel

Constructor Summary

Constructors

Constructor	Description
EmptyChannel(int nId)

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EmptyChannel

public EmptyChannel(int nId)

Method Detail

getId

public int getId()

Description copied from interface: Subscriber.Channel

Returns the identifier for this channel.

Specified by:

getId in interface Subscriber.Channel

Returns:

the identifier for this channel

getHead

public Position getHead()

Description copied from interface: Subscriber.Channel

Returns the current head position for the channel.

Specified by:

getHead in interface Subscriber.Channel

Returns:

the current head position for the channel

getLastCommit

public Position getLastCommit()

Description copied from interface: Subscriber.Channel

Returns the last position committed by this subscriber.

Specified by:

getLastCommit in interface Subscriber.Channel

Returns:

the last position committed by this subscriber

getCommitCount

public long getCommitCount()

Description copied from interface: Subscriber.Channel

Return the number of completed commit requests.

Specified by:

getCommitCount in interface Subscriber.Channel

Returns:

the number of completed commit requests

getLastReceived

public Position getLastReceived()

Description copied from interface: Subscriber.Channel

Returns the last position received by this subscriber.

Specified by:

getLastReceived in interface Subscriber.Channel

Returns:

the last position received by this subscriber

getReceiveCount

public long getReceiveCount()

Description copied from interface: Subscriber.Channel

Return the number of completed receive requests.

Specified by:

getReceiveCount in interface Subscriber.Channel

Returns:

the number of completed receive requests

getPolls

public long getPolls()

Description copied from interface: Subscriber.Channel

Returns the number of elements polled by this subscriber.

Specified by:

getPolls in interface Subscriber.Channel

Returns:

the number of elements polled by this subscriber

getFirstPolled

public Position getFirstPolled()

Description copied from interface: Subscriber.Channel

Returns the first position polled by this subscriber.

Specified by:

getFirstPolled in interface Subscriber.Channel

Returns:

the first position polled by this subscriber

getFirstPolledTimestamp

public long getFirstPolledTimestamp()

Description copied from interface: Subscriber.Channel

Returns the timestamp when the first element was polled by this subscriber.

Specified by:

getFirstPolledTimestamp in interface Subscriber.Channel

Returns:

the timestamp when the first element was polled by this subscriber

getLastPolled

public Position getLastPolled()

Description copied from interface: Subscriber.Channel

Returns the last position polled by this subscriber.

Specified by:

getLastPolled in interface Subscriber.Channel

Returns:

the last position polled by this subscriber

getLastPolledTimestamp

public long getLastPolledTimestamp()

Description copied from interface: Subscriber.Channel

Returns the timestamp when the last element was polled by this subscriber.

Specified by:

getLastPolledTimestamp in interface Subscriber.Channel

Returns:

the timestamp when the last element was polled by this subscriber

isEmpty

public boolean isEmpty()

Description copied from interface: Subscriber.Channel

Returns true if the channel is empty.

Specified by:

isEmpty in interface Subscriber.Channel

Returns:

true if the channel is empty

isOwned

public boolean isOwned()

Description copied from interface: Subscriber.Channel

Returns true if the channel is owned by this subscriber.

Specified by:

isOwned in interface Subscriber.Channel

Returns:

true if the channel is owned by this subscriber

getOwnedCode

public int getOwnedCode()

Description copied from interface: Subscriber.Channel

Returns a numeric representation of if the channel is owned by this subscriber where 1 represents true and 0 represents false.

Specified by:

getOwnedCode in interface Subscriber.Channel

Returns:

a numeric representation of if the channel is owned by this subscriber where 1 represents true and 0 represents false

getReceived

public long getReceived()

Description copied from interface: Subscriber.Channel

Return the number of completed receive requests.

Specified by:

getReceived in interface Subscriber.Channel

Returns:

the number of completed receive requests

getReceivedMeanRate

public double getReceivedMeanRate()

Description copied from interface: Subscriber.Channel

Return the mean rate of completed receive requests.

Specified by:

getReceivedMeanRate in interface Subscriber.Channel

Returns:

the mean rate of completed receive requests

getReceivedOneMinuteRate

public double getReceivedOneMinuteRate()

Description copied from interface: Subscriber.Channel

Return the one-minute rate of completed receive requests.

Specified by:

getReceivedOneMinuteRate in interface Subscriber.Channel

Returns:

the one-minute rate of completed receive requests

getReceivedFiveMinuteRate

public double getReceivedFiveMinuteRate()

Description copied from interface: Subscriber.Channel

Return the five-minute rate of completed receive requests.

Specified by:

getReceivedFiveMinuteRate in interface Subscriber.Channel

Returns:

the five-minute rate of completed receive requests

getReceivedFifteenMinuteRate

public double getReceivedFifteenMinuteRate()

Description copied from interface: Subscriber.Channel

Return the fifteen-minute rate of completed receive requests.

Specified by:

getReceivedFifteenMinuteRate in interface Subscriber.Channel

Returns:

the fifteen-minute rate of completed receive requests