| Package | Description |
|---|---|
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Method and Description |
|---|---|
static PairedDataSender.Builder |
PairedDataSender.builder()
Returns a newly created
PairedDataSender.Builder. |
PairedDataSender.Builder |
PairedDataSender.Builder.deliveryMode(int deliveryMode)
Sets the delivery mode used for the RabbitMQ messages.
|
PairedDataSender.Builder |
PairedDataSender.Builder.idGenerator(IdGenerator idGenerator)
Sets the Id generator used to create unique stream Ids.
|
PairedDataSender.Builder |
PairedDataSender.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.
|
PairedDataSender.Builder |
PairedDataSender.Builder.messageSize(int messageSize)
Sets the size of the messages that will be send.
|
PairedDataSender.Builder |
PairedDataSender.Builder.name(String name) |
PairedDataSender.Builder |
PairedDataSender.Builder.queue(RabbitQueue queue)
Sets the queue that is used to receive data.
|
PairedDataSender.Builder |
PairedDataSender.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–2018. All rights reserved.