| Package | Description |
|---|---|
| org.hobbit.core.components | |
| org.hobbit.core.rabbit |
| Modifier and Type | Field and Description |
|---|---|
protected RabbitQueue |
AbstractSystemAdapter.dataGen2SystemQueue
Queue from the data generator to this evaluation storage.
|
protected RabbitQueue |
AbstractDataGenerator.dataGen2SystemQueue |
protected RabbitQueue |
AbstractTaskGenerator.dataGen2TaskGenQueue |
protected RabbitQueue |
AbstractDataGenerator.dataGen2TaskGenQueue |
protected RabbitQueue |
AbstractEvaluationStorage.evalModule2EvalStoreQueue
The incoming queue from the evaluation module.
|
protected RabbitQueue |
AbstractEvaluationModule.evalModule2EvalStoreQueue
Queue to the evaluation storage.
|
protected RabbitQueue |
AbstractEvaluationModule.evalStore2EvalModuleQueue
Incoming queue from the evaluation storage.
|
protected RabbitQueue |
AbstractSystemAdapter.system2EvalStoreQueue
Queue from the benchmarked system to this evaluation storage.
|
protected RabbitQueue |
AbstractEvaluationStorage.system2EvalStoreQueue
The incoming queue from the system.
|
protected RabbitQueue |
AbstractTaskGenerator.taskGen2EvalStoreQueue |
protected RabbitQueue |
AbstractEvaluationStorage.taskGen2EvalStoreQueue
The incoming queue from the task generator.
|
protected RabbitQueue |
AbstractTaskGenerator.taskGen2SystemQueue |
protected RabbitQueue |
AbstractSystemAdapter.taskGen2SystemQueue
Queue from the task generator to this evaluation storage.
|
| Modifier and Type | Method and Description |
|---|---|
RabbitQueue |
RabbitQueueFactory.createDefaultRabbitQueue(String name)
This method opens a channel using the established connection to RabbitMQ
and creates a new queue using the given name and the following
configuration:
The channel number is automatically derived from the connection.
|
RabbitQueue |
AbstractPlatformConnectorComponent.createDefaultRabbitQueue(String name)
This method opens a channel using the established
AbstractComponent.connection to
RabbitMQ and creates a new queue using the given name and the following
configuration:
The channel number is automatically derived from the connection. |
RabbitQueue |
AbstractComponent.createDefaultRabbitQueue(String name)
This method opens a channel using the established
AbstractComponent.connection to
RabbitMQ and creates a new queue using the given name and the following
configuration:
The channel number is automatically derived from the connection. |
| Modifier and Type | Field and Description |
|---|---|
private RabbitQueue |
SimpleFileSender.queue |
private RabbitQueue |
SimpleFileReceiver.queue |
private RabbitQueue |
RabbitRpcClient.requestQueue
Queue used for the request.
|
private RabbitQueue |
RabbitRpcClient.responseQueue
Queue used for the responses.
|
| Modifier and Type | Method and Description |
|---|---|
static SimpleFileReceiver |
SimpleFileReceiver.create(RabbitQueue queue) |
| Constructor and Description |
|---|
SimpleFileReceiver(RabbitQueue queue,
com.rabbitmq.client.QueueingConsumer consumer) |
SimpleFileSender(RabbitQueue queue) |
Copyright © 2017. All rights reserved.