public class PendingMessages extends Object implements Streamable<PendingMessage>
Range
and offset.Constructor and Description |
---|
PendingMessages(String groupName,
List<PendingMessage> pendingMessages) |
PendingMessages(String groupName,
Range<?> range,
List<PendingMessage> pendingMessages) |
Modifier and Type | Method and Description |
---|---|
PendingMessage |
get(int index)
Get the
PendingMessage at the given position. |
String |
getGroupName()
The consumer group name.
|
Range<?> |
getRange()
The
Range pending messages have been loaded. |
boolean |
isEmpty() |
Iterator<PendingMessage> |
iterator() |
int |
size() |
String |
toString() |
PendingMessages |
withinRange(Range<?> range)
Adds the range to the current
PendingMessages . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
and, and, and, and, empty, filter, flatMap, get, map, of, of, of, stream, toList, toSet, toStreamable, toStreamable
forEach, spliterator
public PendingMessages(String groupName, List<PendingMessage> pendingMessages)
public PendingMessages(String groupName, Range<?> range, List<PendingMessage> pendingMessages)
public PendingMessages withinRange(Range<?> range)
PendingMessages
.range
- must not be null.PendingMessages
.public String getGroupName()
public Range<?> getRange()
Range
pending messages have been loaded.public boolean isEmpty()
isEmpty
in interface Streamable<PendingMessage>
public int size()
public PendingMessage get(int index)
PendingMessage
at the given position.index
- PendingMessage
a the given index.IndexOutOfBoundsException
- if the index is out of range.public Iterator<PendingMessage> iterator()
iterator
in interface Iterable<PendingMessage>
Copyright © 2011–2021 Pivotal Software, Inc.. All rights reserved.