| 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 DataReceiver |
AbstractEvaluationStorage.systemResultReceiver
The incoming queue from the system.
|
protected DataReceiver |
AbstractEvaluationStorage.taskResultReceiver
The incoming queue from the task generator.
|
| Constructor and Description |
|---|
AbstractSystemAdapter(DataSender sender2EvalStore,
DataReceiver dataReceiver,
DataReceiver taskReceiver) |
| Modifier and Type | Field and Description |
|---|---|
protected DataReceiver |
AbstractStreamingSystemAdapter.dataGenReceiver
Receiver for data coming from the data generator.
|
protected DataReceiver |
AbstractStreamingTaskGenerator.dataReceiver
Receiver for receiving data from the data generators.
|
protected DataReceiver |
AbstractStreamingSystemAdapter.taskGenReceiver
Receiver for tasks coming from the task generator.
|
| Constructor and Description |
|---|
AbstractStreamingSystemAdapter(DataSender sender2EvalStore,
DataReceiver dataGenReceiver,
DataReceiver taskGenReceiver) |
| Modifier and Type | Class and Description |
|---|---|
class |
DataReceiverImpl
Implementation of the
DataReceiver interface. |
| Modifier and Type | Field and Description |
|---|---|
protected DataReceiver |
QueueingConsumerBasedImpl.receiver
The
DataReceiver which is using this consumer. |
protected DataReceiver |
AbstractMessageConsumer.receiver
The
DataReceiver which is using this consumer. |
| Constructor and Description |
|---|
AbstractMessageConsumer(DataReceiver receiver,
com.rabbitmq.client.Channel channel,
int maxParallelProcessedMsgs,
String name) |
MessageConsumerImpl(DataReceiver receiver,
com.rabbitmq.client.Channel channel,
int maxParallelProcessedMsgs)
Deprecated.
|
MessageConsumerImpl(DataReceiver receiver,
com.rabbitmq.client.Channel channel,
int maxParallelProcessedMsgs,
String name)
Deprecated.
|
QueueingConsumerBasedImpl(DataReceiver receiver,
RabbitQueue queue,
int maxParallelProcessedMsgs) |
QueueingConsumerBasedImpl(DataReceiver receiver,
RabbitQueue queue,
int maxParallelProcessedMsgs,
String name) |
| Constructor and Description |
|---|
PairedConsumerImpl(DataReceiver receiver,
com.rabbitmq.client.Channel channel,
int maxParallelProcessedMsgs) |
PairedConsumerImpl(DataReceiver receiver,
com.rabbitmq.client.Channel channel,
int maxParallelProcessedMsgs,
String name) |
Copyright © 2017–2018. All rights reserved.