Package io.awspring.cloud.sqs.listener.backpressure

Class ConcurrencyLimiterBlockingBackPressureHandler.Builder

java.lang.Object

io.awspring.cloud.sqs.listener.backpressure.ConcurrencyLimiterBlockingBackPressureHandler.Builder

Enclosing class:

ConcurrencyLimiterBlockingBackPressureHandler

public static class ConcurrencyLimiterBlockingBackPressureHandler.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
ConcurrencyLimiterBlockingBackPressureHandler.Builder	acquireTimeout(Duration acquireTimeout)
ConcurrencyLimiterBlockingBackPressureHandler.Builder	batchSize(int batchSize)
ConcurrencyLimiterBlockingBackPressureHandler	build()
ConcurrencyLimiterBlockingBackPressureHandler.Builder	totalPermits(int totalPermits)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

batchSize

public ConcurrencyLimiterBlockingBackPressureHandler.Builder batchSize(int batchSize)

totalPermits

public ConcurrencyLimiterBlockingBackPressureHandler.Builder totalPermits(int totalPermits)

acquireTimeout

public ConcurrencyLimiterBlockingBackPressureHandler.Builder acquireTimeout(Duration acquireTimeout)

build

public ConcurrencyLimiterBlockingBackPressureHandler build()