org.dice_research.squirrel.rabbit

Class RPCServer.Builder

java.lang.Object

org.hobbit.core.rabbit.DataReceiverImpl.Builder

org.dice_research.squirrel.rabbit.RPCServer.Builder

Enclosing class:

RPCServer

public static class RPCServer.Builder
extends org.hobbit.core.rabbit.DataReceiverImpl.Builder

Field Summary

Fields

Modifier and Type	Field and Description
private org.hobbit.core.rabbit.RabbitQueueFactory	responseFactory

Fields inherited from class org.hobbit.core.rabbit.DataReceiverImpl.Builder

DATA_HANDLER_MISSING_ERROR, dataHandler, factory, maxParallelProcessedMsgs, queue, QUEUE_INFO_MISSING_ERROR, queueName

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
org.hobbit.core.rabbit.DataReceiverImpl	build() Builds the DataReceiverImpl instance with the previously given information.
RPCServer.Builder	dataHandler(org.hobbit.core.rabbit.DataHandler dataHandler) Sets the handler that is called if data is incoming.
RPCServer.Builder	maxParallelProcessedMsgs(int maxParallelProcessedMsgs) Sets the maximum number of incoming messages that are processed in parallel.
RPCServer.Builder	responseQueueFactory(org.hobbit.core.rabbit.RabbitQueueFactory factory) Method for providing the necessary information to connect to the queue to which responses should be sent.

Methods inherited from class org.hobbit.core.rabbit.DataReceiverImpl.Builder

queue, queue

Methods inherited from class java.lang.Object

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

Field Detail

responseFactory

private org.hobbit.core.rabbit.RabbitQueueFactory responseFactory

Constructor Detail

Builder

public Builder()

Method Detail

dataHandler

public RPCServer.Builder dataHandler(org.hobbit.core.rabbit.DataHandler dataHandler)

Sets the handler that is called if data is incoming. Note that a RespondingDataHandler is expected.

Overrides:

dataHandler in class org.hobbit.core.rabbit.DataReceiverImpl.Builder

Parameters:

dataHandler - the RespondingDataHandler instance that is called if data is incoming

Returns:

this builder instance

responseQueueFactory

public RPCServer.Builder responseQueueFactory(org.hobbit.core.rabbit.RabbitQueueFactory factory)

Method for providing the necessary information to connect to the queue to which responses should be sent. Note that if this information is not provided, the RPCServer instance is still working but might have performance problems or might get stuck.

Parameters:

factory - the queue factory used to connect to

Returns:

this builder instance

maxParallelProcessedMsgs

public RPCServer.Builder maxParallelProcessedMsgs(int maxParallelProcessedMsgs)

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

Overrides:

maxParallelProcessedMsgs in class org.hobbit.core.rabbit.DataReceiverImpl.Builder

Parameters:

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

Returns:

this builder instance

build

public org.hobbit.core.rabbit.DataReceiverImpl build()
                                              throws IllegalStateException,
                                                     IOException

Builds the DataReceiverImpl instance with the previously given information.

Overrides:

build in class org.hobbit.core.rabbit.DataReceiverImpl.Builder

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.