public class MessageIdStopCursor extends Object implements StopCursor
Comparable.compareTo(Object)
for
compare the consuming message with the given message id.StopCursor.StopCondition
Constructor and Description |
---|
MessageIdStopCursor(org.apache.pulsar.client.api.MessageId messageId,
boolean inclusive) |
Modifier and Type | Method and Description |
---|---|
StopCursor.StopCondition |
shouldStop(org.apache.pulsar.client.api.Message<?> message)
Determine whether to pause consumption on the current message by the returned enum.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterEventTime, afterMessageId, afterPublishTime, atEventTime, atMessageId, atPublishTime, defaultStopCursor, latest, never, open
public MessageIdStopCursor(org.apache.pulsar.client.api.MessageId messageId, boolean inclusive)
public StopCursor.StopCondition shouldStop(org.apache.pulsar.client.api.Message<?> message)
StopCursor
shouldStop
in interface StopCursor
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.