| Package | Description |
|---|---|
| org.hobbit.core.rabbit | |
| org.hobbit.core.rabbit.consume | |
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Field and Description |
|---|---|
private MessageConsumerBuilder |
DataReceiverImpl.Builder.consumerBuilder |
| Modifier and Type | Method and Description |
|---|---|
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.consumerBuilder(MessageConsumerBuilder consumerBuilder)
Sets the
MessageConsumerBuilder which is used to create the
MessageConsumer for the created DataReceiverImpl. |
| Constructor and Description |
|---|
DataReceiverImpl(RabbitQueue queue,
IncomingStreamHandler handler,
MessageConsumerBuilder consumerBuilder,
int maxParallelProcessedMsgs,
String name) |
| Modifier and Type | Class and Description |
|---|---|
static class |
MessageConsumerImpl.Builder
Deprecated.
|
static class |
QueueingConsumerBasedImpl.Builder |
| Modifier and Type | Method and Description |
|---|---|
MessageConsumerBuilder |
MessageConsumerBuilder.maxParallelProcessedMsgs(int maxParallelProcessedMsgs) |
MessageConsumerBuilder |
QueueingConsumerBasedImpl.Builder.maxParallelProcessedMsgs(int maxParallelProcessedMsgs) |
MessageConsumerBuilder |
MessageConsumerImpl.Builder.maxParallelProcessedMsgs(int maxParallelProcessedMsgs) |
MessageConsumerBuilder |
MessageConsumerBuilder.name(String name) |
| Modifier and Type | Class and Description |
|---|---|
static class |
PairedConsumerImpl.Builder |
| Modifier and Type | Method and Description |
|---|---|
MessageConsumerBuilder |
PairedConsumerImpl.Builder.maxParallelProcessedMsgs(int maxParallelProcessedMsgs) |
Copyright © 2017–2018. All rights reserved.