org.apache.pulsar.common.policies.data

Class ConsumerStats

java.lang.Object

org.apache.pulsar.common.policies.data.ConsumerStats

public class ConsumerStats
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
int	availablePermits Number of available message permits for the consumer
boolean	blockedConsumerOnUnackedMsgs Flag to verify if consumer is blocked due to reaching threshold of unacked messages
String	consumerName Name of the consumer
Map<String,String>	metadata Metadata (key/value strings) associated with this consumer
double	msgRateOut Total rate of messages delivered to the consumer.
double	msgRateRedeliver Total rate of messages redelivered by this consumer.
double	msgThroughputOut Total throughput delivered to the consumer.
int	unackedMessages Number of unacknowledged messages for the consumer

Constructor Summary

Constructors

Constructor and Description
ConsumerStats()

Method Summary

Modifier and Type	Method and Description
ConsumerStats	add(ConsumerStats stats)
String	getAddress()
String	getClientVersion()
String	getConnectedSince()
void	setAddress(String address)
void	setClientVersion(String clientVersion)
void	setConnectedSince(String connectedSince)

Methods inherited from class java.lang.Object

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

Field Detail

msgRateOut

public double msgRateOut

Total rate of messages delivered to the consumer. msg/s

msgThroughputOut

public double msgThroughputOut

Total throughput delivered to the consumer. bytes/s

msgRateRedeliver

public double msgRateRedeliver

Total rate of messages redelivered by this consumer. msg/s

consumerName

public String consumerName

Name of the consumer

availablePermits

public int availablePermits

Number of available message permits for the consumer

unackedMessages

public int unackedMessages

Number of unacknowledged messages for the consumer

blockedConsumerOnUnackedMsgs

public boolean blockedConsumerOnUnackedMsgs

Flag to verify if consumer is blocked due to reaching threshold of unacked messages

metadata

public Map<String,String> metadata

Metadata (key/value strings) associated with this consumer

Constructor Detail

ConsumerStats

public ConsumerStats()

Method Detail

add

public ConsumerStats add(ConsumerStats stats)

getAddress

public String getAddress()

setAddress

public void setAddress(String address)

getConnectedSince

public String getConnectedSince()

setConnectedSince

public void setConnectedSince(String connectedSince)

getClientVersion

public String getClientVersion()

setClientVersion

public void setClientVersion(String clientVersion)