org.hobbit.core.rabbit

Class DataSenderImpl.Builder

java.lang.Object

org.hobbit.core.rabbit.DataSenderImpl.Builder

Direct Known Subclasses:

PairedDataSender.Builder

Enclosing class:

DataSenderImpl

public static class DataSenderImpl.Builder
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected int	deliveryMode
protected RabbitQueueFactory	factory
protected IdGenerator	idGenerator
protected int	messageConfirmBuffer
protected int	messageSize
protected String	name
protected RabbitQueue	queue
protected static String	QUEUE_INFO_MISSING_ERROR
protected String	queueName

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
DataSenderImpl	build() Builds the DataReceiverImpl instance with the previously given information.
DataSenderImpl.Builder	deliveryMode(int deliveryMode) Sets the delivery mode used for the RabbitMQ messages.
DataSenderImpl.Builder	idGenerator(IdGenerator idGenerator) Sets the Id generator used to create unique stream Ids.
DataSenderImpl.Builder	messageBuffer(int messageConfirmBuffer) Sets the number of messages that are buffered while waiting for a confirmation that they have been received by the broker.
DataSenderImpl.Builder	messageSize(int messageSize) Sets the size of the messages that will be send.
DataSenderImpl.Builder	name(String name)
DataSenderImpl.Builder	queue(RabbitQueue queue) Sets the queue that is used to receive data.
DataSenderImpl.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

protected static final String QUEUE_INFO_MISSING_ERROR

See Also:

Constant Field Values

idGenerator

protected IdGenerator idGenerator

queue

protected RabbitQueue queue

queueName

protected String queueName

factory

protected RabbitQueueFactory factory

messageSize

protected int messageSize

messageConfirmBuffer

protected int messageConfirmBuffer

deliveryMode

protected int deliveryMode

name

protected String name

Constructor Detail

Builder

public Builder()

Method Detail

idGenerator

public DataSenderImpl.Builder idGenerator(IdGenerator idGenerator)

Sets the Id generator used to create unique stream Ids.

Parameters:

dataHandler - the Id generator used to create unique stream Ids

Returns:

this builder instance

queue

public DataSenderImpl.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 DataSenderImpl.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

messageSize

public DataSenderImpl.Builder messageSize(int messageSize)

Sets the size of the messages that will be send. Note that the maximum size of a message can be 2 * the given value.

Parameters:

messageSize - the size of the messages that will be send

Returns:

this builder instance

messageBuffer

public DataSenderImpl.Builder messageBuffer(int messageConfirmBuffer)

Sets the number of messages that are buffered while waiting for a confirmation that they have been received by the broker. Note that if the message buffer has reached is maximum size, the sender will block until confirmations are received.

If the given message buffer size is <1 the usage of confirmation messages is turned off.

Parameters:

messageConfirmBuffer - the size of the messages buffer

Returns:

this builder instance

deliveryMode

public DataSenderImpl.Builder deliveryMode(int deliveryMode)

Sets the delivery mode used for the RabbitMQ messages. Please have a look into the RabbitMQ documentation to see the different meanings of the values. By default, the sender uses DataSenderImpl.DEFAULT_DELIVERY_MODE.

Parameters:

deliveryMode - the delivery mode used for the RabbitMQ messages

Returns:

this builder instance

name

public DataSenderImpl.Builder name(String name)

build

public DataSenderImpl build()
                     throws IllegalStateException,
                            IOException

Builds the DataReceiverImpl instance with the previously given information.

Returns:

The newly created DataReceiver instance

Throws:

IllegalStateException - 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.