Package at.letto.queue

Class TaskQueue.Builder<T,K>

java.lang.Object

at.letto.queue.TaskQueue.Builder<T,K>

Enclosing class:

TaskQueue<T,K>

public static final class TaskQueue.Builder<T,K>
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private TaskQueue.ErrorHandler<T>	errorHandler
private Duration	idleStop
private Function<T,K>	keyExtractor
private TaskQueue.TaskProcessor<T>	processor
private Duration	restartPeriod

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
TaskQueue<T,K>	build()
TaskQueue.Builder<T,K>	errorHandler(TaskQueue.ErrorHandler<T> h)
TaskQueue.Builder<T,K>	idleStop(Duration d)
TaskQueue.Builder<T,K>	keyExtractor(Function<T,K> k)
TaskQueue.Builder<T,K>	processor(TaskQueue.TaskProcessor<T> p)
TaskQueue.Builder<T,K>	restartPeriod(Duration d)

Methods inherited from class java.lang.Object

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

Field Details

processor

private TaskQueue.TaskProcessor<T> processor

keyExtractor

private Function<T,K> keyExtractor

idleStop

private Duration idleStop

restartPeriod

private Duration restartPeriod

errorHandler

private TaskQueue.ErrorHandler<T> errorHandler

Constructor Details

Builder

public Builder()

Method Details

processor

public TaskQueue.Builder<T,K> processor(TaskQueue.TaskProcessor<T> p)

keyExtractor

public TaskQueue.Builder<T,K> keyExtractor(Function<T,K> k)

idleStop

public TaskQueue.Builder<T,K> idleStop(Duration d)

restartPeriod

public TaskQueue.Builder<T,K> restartPeriod(Duration d)

errorHandler

public TaskQueue.Builder<T,K> errorHandler(TaskQueue.ErrorHandler<T> h)

build

public TaskQueue<T,K> build()