@PublicEvolving public class FixedMessageDelayer<IN> extends Object implements MessageDelayer<IN>
Constructor and Description |
---|
FixedMessageDelayer(long delayDuration) |
Modifier and Type | Method and Description |
---|---|
long |
deliverAt(IN message,
PulsarSinkContext sinkContext)
Return the send time for this message.
|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
fixed, never, open
public long deliverAt(IN message, PulsarSinkContext sinkContext)
MessageDelayer
PulsarSinkContext.processTime()
and the non-positive value indicate this message should be
sent immediately.deliverAt
in interface MessageDelayer<IN>
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.