| Package | Description |
|---|---|
| org.hobbit.core.rabbit | |
| org.hobbit.core.rabbit.consume | |
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Field and Description |
|---|---|
private MessageConsumer |
DataReceiverImpl.consumer |
| Modifier and Type | Class and Description |
|---|---|
class |
AbstractMessageConsumer |
class |
MessageConsumerImpl
Deprecated.
Has major problems receiving all the submitted data. Use
QueueingConsumerBasedImpl
instead. |
class |
QueueingConsumerBasedImpl |
| Modifier and Type | Method and Description |
|---|---|
MessageConsumer |
MessageConsumerBuilder.build(DataReceiverImpl receiver,
RabbitQueue queue)
Builds a consumer for the given
DataReceiver |
MessageConsumer |
QueueingConsumerBasedImpl.Builder.build(DataReceiverImpl receiver,
RabbitQueue queue) |
MessageConsumer |
MessageConsumerImpl.Builder.build(DataReceiverImpl receiver,
RabbitQueue queue) |
| Modifier and Type | Class and Description |
|---|---|
class |
PairedConsumerImpl |
| Modifier and Type | Method and Description |
|---|---|
MessageConsumer |
PairedConsumerImpl.Builder.build(DataReceiverImpl receiver,
RabbitQueue queue) |
Copyright © 2017–2018. All rights reserved.