PubSubScheduler
Shared scheduler interface for delayed publish and retry across all transports.
Methods
Section titled “Methods”close()
Section titled “close()”close():
Promise<void>
Stop the scheduler and clear in-process timers.
Returns
Section titled “Returns”Promise<void>
publishLater()
Section titled “publishLater()”publishLater(
request):Promise<void>
Persist and schedule a delayed publish request.
Parameters
Section titled “Parameters”request
Section titled “request”Returns
Section titled “Returns”Promise<void>
retryLater()
Section titled “retryLater()”retryLater(
topic,event,delayMs,attempt):Promise<void>
Persist and schedule a retry for an already delivered CloudEvent.
Parameters
Section titled “Parameters”string
CloudEvent
delayMs
Section titled “delayMs”number
attempt
Section titled “attempt”number
Returns
Section titled “Returns”Promise<void>
start()
Section titled “start()”start():
Promise<void>
Start consuming durable schedule records.
Returns
Section titled “Returns”Promise<void>