PostboxProcessing
class PostboxProcessing(transactor: PostboxTransactor, target: HttpHandler, batchSize: Int = 10, maxFailures: Int = 3, maxPollingTime: Duration = Duration.ofSeconds(5), events: Events = { }, context: ExecutionContext = DefaultExecutionContext, backoffStrategy: BackoffStrategy = ::defaultBackoffStrategy, successCriteria: (Response) -> Boolean = { it.status.successful })
PostboxProcessing is a background process that polls the Postbox for pending requests and processes them.
Constructors
Link copied to clipboard
constructor(transactor: PostboxTransactor, target: HttpHandler, batchSize: Int = 10, maxFailures: Int = 3, maxPollingTime: Duration = Duration.ofSeconds(5), events: Events = { }, context: ExecutionContext = DefaultExecutionContext, backoffStrategy: BackoffStrategy = ::defaultBackoffStrategy, successCriteria: (Response) -> Boolean = { it.status.successful })
Functions
Link copied to clipboard
fun processPendingRequests(successCriteria: (Response) -> Boolean): Result<Int, RequestProcessingError>