public class BoundedSSPIterator extends java.lang.Object implements java.util.Iterator<IncomingMessageEnvelope>
SystemStreamPartition
using the provided
SystemConsumer
until all messages with offsets up to and including the endOffset
have been consumed.
If endOffset
is null, the iterator will return all messages until caught up to head.Modifier and Type | Field and Description |
---|---|
protected SystemAdmin |
admin |
Constructor and Description |
---|
BoundedSSPIterator(SystemConsumer systemConsumer,
SystemStreamPartition systemStreamPartition,
java.lang.String endOffset,
SystemAdmin admin) |
Modifier and Type | Method and Description |
---|---|
boolean |
hasNext() |
IncomingMessageEnvelope |
next() |
protected final SystemAdmin admin
public BoundedSSPIterator(SystemConsumer systemConsumer, SystemStreamPartition systemStreamPartition, java.lang.String endOffset, SystemAdmin admin)
public boolean hasNext()
hasNext
in interface java.util.Iterator<IncomingMessageEnvelope>
public IncomingMessageEnvelope next()
next
in interface java.util.Iterator<IncomingMessageEnvelope>