org.hobbit.core.rabbit

Class DataReceiverImpl.Builder

java.lang.Object

org.hobbit.core.rabbit.DataReceiverImpl.Builder

Enclosing class:

DataReceiverImpl

public static final class DataReceiverImpl.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
private MessageConsumerBuilder	consumerBuilder
private static String	DATA_HANDLER_MISSING_ERROR
private IncomingStreamHandler	dataHandler
private RabbitQueueFactory	factory
private int	maxParallelProcessedMsgs
private String	name
private RabbitQueue	queue
private static String	QUEUE_INFO_MISSING_ERROR
private String	queueName

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
DataReceiverImpl	build() Builds the DataReceiverImpl instance with the previously given information.
DataReceiverImpl.Builder	consumerBuilder(MessageConsumerBuilder consumerBuilder) Sets the MessageConsumerBuilder which is used to create the MessageConsumer for the created DataReceiverImpl.
DataReceiverImpl.Builder	dataHandler(IncomingStreamHandler dataHandler) Sets the handler that is called if data is incoming.
DataReceiverImpl.Builder	maxParallelProcessedMsgs(int maxParallelProcessedMsgs) Sets the maximum number of incoming messages that are processed in parallel.
DataReceiverImpl.Builder	name(String name)
DataReceiverImpl.Builder	queue(RabbitQueue queue) Sets the queue that is used to receive data.
DataReceiverImpl.Builder	queue(RabbitQueueFactory factory, String queueName) Method for providing the necessary information to create a queue if it has not been provided with the queue(RabbitQueue) method.

Methods inherited from class java.lang.Object

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

Field Detail

QUEUE_INFO_MISSING_ERROR

private static final String QUEUE_INFO_MISSING_ERROR

See Also:

Constant Field Values

DATA_HANDLER_MISSING_ERROR

private static final String DATA_HANDLER_MISSING_ERROR

See Also:

Constant Field Values

dataHandler

private IncomingStreamHandler dataHandler

queue

private RabbitQueue queue

queueName

private String queueName

maxParallelProcessedMsgs

private int maxParallelProcessedMsgs

factory

private RabbitQueueFactory factory

consumerBuilder

private MessageConsumerBuilder consumerBuilder

name

private String name

Constructor Detail

Builder

public Builder()

Method Detail

dataHandler

public DataReceiverImpl.Builder dataHandler(IncomingStreamHandler dataHandler)

Sets the handler that is called if data is incoming.

Parameters:

dataHandler - the handler that is called if data is incoming

Returns:

this builder instance

queue

public DataReceiverImpl.Builder queue(RabbitQueue queue)

Sets the queue that is used to receive data.

Parameters:

queue - the queue that is used to receive data

Returns:

this builder instance

queue

public DataReceiverImpl.Builder queue(RabbitQueueFactory factory,
                                      String queueName)

Method for providing the necessary information to create a queue if it has not been provided with the queue(RabbitQueue) method. Note that this information is not used if a queue has been provided.

Parameters:

factory - the queue factory used to create a queue

queueName - the name of the newly created queue

Returns:

this builder instance

maxParallelProcessedMsgs

public DataReceiverImpl.Builder maxParallelProcessedMsgs(int maxParallelProcessedMsgs)

Sets the maximum number of incoming messages that are processed in parallel. Additional messages have to wait in the queue.

Parameters:

maxParallelProcessedMsgs - the maximum number of incoming messages that are processed in parallel

Returns:

this builder instance

consumerBuilder

public DataReceiverImpl.Builder consumerBuilder(MessageConsumerBuilder consumerBuilder)

Sets the MessageConsumerBuilder which is used to create the MessageConsumer for the created DataReceiverImpl.

Parameters:

consumerBuilder - the builder used to create the consumer

Returns:

this builder instance

name

public DataReceiverImpl.Builder name(String name)

build

public DataReceiverImpl build()
                       throws IllegalStateException,
                              IOException

Builds the DataReceiverImpl instance with the previously given information.

Returns:

The newly created DataReceiver instance

Throws:

IllegalStateException - if the dataHandler is missing or if neither a queue nor the information needed to create a queue have been provided.

IOException - if an exception is thrown while creating a new queue or if the given queue can not be configured by the newly created DataReceiver. Note that in the latter case the queue will be closed.