| Package | Description |
|---|---|
| org.hobbit.core.rabbit |
| Modifier and Type | Method | Description |
|---|---|---|
static DataReceiverImpl.Builder |
DataReceiverImpl.builder() |
Returns a newly created
DataReceiverImpl.Builder. |
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.dataHandler(DataHandler dataHandler) |
Sets the handler that is called if data is incoming.
|
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.maxParallelProcessedMsgs(int maxParallelProcessedMsgs) |
Sets the maximum number of incoming messages that are processed in parallel.
|
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.queue(RabbitQueue queue) |
Sets the queue that is used to receive data.
|
DataReceiverImpl.Builder |
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. |
Copyright © 2017. All rights reserved.