org.apache.pulsar.common.policies.data

Class SubscriptionStats

java.lang.Object

org.apache.pulsar.common.policies.data.SubscriptionStats

Direct Known Subclasses:

NonPersistentSubscriptionStats

public class SubscriptionStats
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
String	activeConsumerName The name of the consumer that is active for single active consumer subscriptions i.e.
boolean	blockedSubscriptionOnUnackedMsgs Flag to verify if subscription is blocked due to reaching threshold of unacked messages
List<ConsumerStats>	consumers List of connected consumers on this subscription w/ their stats
long	msgBacklog Number of messages in the subscription backlog
double	msgRateExpired Total rate of messages expired on this subscription.
double	msgRateOut Total rate of messages delivered on this subscription.
double	msgRateRedeliver Total rate of messages redelivered on this subscription.
double	msgThroughputOut Total throughput delivered on this subscription.
PulsarApi.CommandSubscribe.SubType	type Whether this subscription is Exclusive or Shared or Failover
long	unackedMessages Number of unacknowledged messages for the subscription

Constructor Summary

Constructors

Constructor and Description
SubscriptionStats()

Method Summary

Modifier and Type	Method and Description
SubscriptionStats	add(SubscriptionStats stats)
void	reset()

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 on this subscription. msg/s

msgThroughputOut

public double msgThroughputOut

Total throughput delivered on this subscription. bytes/s

msgRateRedeliver

public double msgRateRedeliver

Total rate of messages redelivered on this subscription. msg/s

msgBacklog

public long msgBacklog

Number of messages in the subscription backlog

blockedSubscriptionOnUnackedMsgs

public boolean blockedSubscriptionOnUnackedMsgs

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

unackedMessages

public long unackedMessages

Number of unacknowledged messages for the subscription

type

public PulsarApi.CommandSubscribe.SubType type

Whether this subscription is Exclusive or Shared or Failover

activeConsumerName

public String activeConsumerName

The name of the consumer that is active for single active consumer subscriptions i.e. failover or exclusive

msgRateExpired

public double msgRateExpired

Total rate of messages expired on this subscription. msg/s

consumers

public List<ConsumerStats> consumers

List of connected consumers on this subscription w/ their stats

Constructor Detail

SubscriptionStats

public SubscriptionStats()

Method Detail

reset

public void reset()

add

public SubscriptionStats add(SubscriptionStats stats)