public class PendingMessagesSummary extends Object
Constructor and Description |
---|
PendingMessagesSummary(String groupName,
long totalPendingMessages,
Range<String> idRange,
Map<String,Long> pendingMessagesPerConsumer) |
Modifier and Type | Method and Description |
---|---|
String |
getGroupName() |
Range<String> |
getIdRange()
Get the range between the smallest and greatest ID among the pending messages.
|
Map<String,Long> |
getPendingMessagesPerConsumer()
Obtain a map of every consumer in the consumer group with at least one pending message, and
the number of pending messages.
|
long |
getTotalPendingMessages()
Get the number of total pending messages within the consumer group.
|
String |
maxMessageId()
Get the greatest ID as
String among the pending messages. |
RecordId |
maxRecordId()
Get the greatest ID among the pending messages.
|
String |
minMessageId()
Get the smallest ID as
String among the pending messages. |
RecordId |
minRecordId()
Get the smallest ID among the pending messages.
|
String |
toString() |
public Range<String> getIdRange()
public RecordId minRecordId()
public RecordId maxRecordId()
public String minMessageId()
String
among the pending messages.public String maxMessageId()
String
among the pending messages.public long getTotalPendingMessages()
public String getGroupName()
public Map<String,Long> getPendingMessagesPerConsumer()
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.