| Package | Description |
|---|---|
| org.hobbit.core.components | |
| org.hobbit.core.components.stream | |
| org.hobbit.core.rabbit | |
| org.hobbit.core.rabbit.consume | |
| org.hobbit.core.rabbit.paired |
| Modifier and Type | Field and Description |
|---|---|
protected DataReceiverImpl |
AbstractEvaluationStorage.expResponseReceiver
The incoming queue from the task generator.
|
protected DataReceiverImpl |
AbstractEvaluationStorage.systemResponseReceiver
The incoming queue from the system.
|
| Modifier and Type | Field and Description |
|---|---|
protected DataReceiverImpl |
AbstractStreamingEvaluationModule.receiver |
| Modifier and Type | Method and Description |
|---|---|
DataReceiverImpl |
DataReceiverImpl.Builder.build()
Builds the
DataReceiverImpl instance with the previously given
information. |
| 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 | Method and Description |
|---|---|
MessageConsumer |
PairedConsumerImpl.Builder.build(DataReceiverImpl receiver,
RabbitQueue queue) |
Copyright © 2017–2018. All rights reserved.