Class ProcessingTimeoutPolicy.Builder

java.lang.Object

org.apache.pulsar.client.api.v5.config.ProcessingTimeoutPolicy.Builder

Enclosing class:

ProcessingTimeoutPolicy

public static final class ProcessingTimeoutPolicy.Builder
extends Object

Builder for ProcessingTimeoutPolicy.

Method Summary

Modifier and Type	Method	Description
ProcessingTimeoutPolicy	build()
ProcessingTimeoutPolicy.Builder	redeliveryBackoff(BackoffPolicy redeliveryBackoff)	Optional backoff applied between redeliveries.
ProcessingTimeoutPolicy.Builder	timeout(Duration timeout)	Processing-timeout duration — how long the client waits for the application to ack before asking the broker to redeliver.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

timeout

public ProcessingTimeoutPolicy.Builder timeout(Duration timeout)

Processing-timeout duration — how long the client waits for the application to ack before asking the broker to redeliver. Duration.ZERO disables. Required.

Parameters:

timeout - the processing timeout

Returns:

this builder

redeliveryBackoff

public ProcessingTimeoutPolicy.Builder redeliveryBackoff(BackoffPolicy redeliveryBackoff)

Optional backoff applied between redeliveries. null (default) means "redeliver immediately on the next sweep".

Parameters:

redeliveryBackoff - the backoff policy

Returns:

this builder

build

public ProcessingTimeoutPolicy build()

Returns:

a new ProcessingTimeoutPolicy instance