Package org.springframework.batch.item.queue.builder

Class BlockingQueueItemReaderBuilder<T>

java.lang.Object

org.springframework.batch.item.queue.builder.BlockingQueueItemReaderBuilder<T>

Type Parameters:

T - type of items to read

public class BlockingQueueItemReaderBuilder<T>
extends Object

Builder for BlockingQueueItemReader.

Since:

5.2.0

Author:

Mahmoud Ben Hassine

Constructor Summary

Constructors

Constructor	Description
BlockingQueueItemReaderBuilder()

Method Summary

Modifier and Type	Method	Description
BlockingQueueItemReader<T>	build()	Create a configured BlockingQueueItemReader.
BlockingQueueItemReaderBuilder<T>	queue(BlockingQueue<T> queue)	Set the queue to read items from.
BlockingQueueItemReaderBuilder<T>	timeout(long timeout, TimeUnit timeUnit)	Set the reading timeout.

Methods inherited from class java.lang.Object

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

Constructor Details

BlockingQueueItemReaderBuilder

public BlockingQueueItemReaderBuilder()

Method Details

queue

public BlockingQueueItemReaderBuilder<T> queue(BlockingQueue<T> queue)

Set the queue to read items from.

Parameters:

queue - the queue to read items from.

Returns:

this instance of the builder

timeout

public BlockingQueueItemReaderBuilder<T> timeout(long timeout,
 TimeUnit timeUnit)

Set the reading timeout. Defaults to 1 second.

Parameters:

timeout - the reading timeout.

Returns:

this instance of the builder

build

public BlockingQueueItemReader<T> build()

Create a configured BlockingQueueItemReader.

Returns:

a configured BlockingQueueItemReader.