public class TimestampStopCursor extends Object implements StopCursor
Constructor and Description |
---|
TimestampStopCursor(long timestamp) |
Modifier and Type | Method and Description |
---|---|
boolean |
shouldStop(org.apache.pulsar.client.api.Message<?> message)
Determine whether to pause consumption on the current message by the returned boolean value.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
afterMessageId, atEventTime, atMessageId, defaultStopCursor, latest, never, open
public boolean shouldStop(org.apache.pulsar.client.api.Message<?> message)
StopCursor
shouldStop
in interface StopCursor
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.