| Package | Description |
|---|---|
| org.hobbit.core.components | |
| org.hobbit.core.rabbit |
| Modifier and Type | Field | Description |
|---|---|---|
protected RabbitQueue |
AbstractEvaluationModule.evalModule2EvalStoreQueue |
Queue to the evaluation storage.
|
protected RabbitQueue |
AbstractEvaluationStorage.evalModule2EvalStoreQueue |
The incoming queue from the evaluation module.
|
protected RabbitQueue |
AbstractEvaluationModule.evalStore2EvalModuleQueue |
Incoming queue from the evaluation storage.
|
| Modifier and Type | Field | Description |
|---|---|---|
protected RabbitQueue |
DataReceiverImpl.Builder.queue |
|
protected RabbitQueue |
DataReceiverImpl.queue |
|
protected RabbitQueue |
DataSenderImpl.Builder.queue |
|
private RabbitQueue |
DataSenderImpl.queue |
|
protected RabbitQueue |
SimpleFileReceiver.queue |
|
private RabbitQueue |
SimpleFileSender.queue |
|
private RabbitQueue |
RabbitRpcClient.requestQueue |
Queue used for the request.
|
private RabbitQueue |
RabbitRpcClient.responseQueue |
Queue used for the responses.
|
| Modifier and Type | Method | 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.
The queue is not durable.
The queue is not exclusive.
The queue is configured to be deleted automatically.
No additional queue configuration is defined.
|
RabbitQueue |
RabbitQueueFactory.createDefaultRabbitQueue(String name,
com.rabbitmq.client.Channel channel) |
This method uses the given channel and creates a new queue using the
given name and the following configuration:
The queue is not durable.
The queue is not exclusive.
The queue is configured to be deleted automatically.
No additional queue configuration is defined.
|
RabbitQueue |
RabbitQueueFactoryImpl.createDefaultRabbitQueue(String name) |
|
RabbitQueue |
RabbitQueueFactoryImpl.createDefaultRabbitQueue(String name,
com.rabbitmq.client.Channel channel) |
|
RabbitQueue |
DataReceiver.getQueue() |
|
RabbitQueue |
DataReceiverImpl.getQueue() |
| Modifier and Type | Method | Description |
|---|---|---|
static SimpleFileReceiver |
SimpleFileReceiver.create(RabbitQueue queue) |
|
DataReceiverImpl.Builder |
DataReceiverImpl.Builder.queue(RabbitQueue queue) |
Sets the queue that is used to receive data.
|
DataSenderImpl.Builder |
DataSenderImpl.Builder.queue(RabbitQueue queue) |
Sets the queue that is used to receive data.
|
| Constructor | Description |
|---|---|
DataReceiverImpl(RabbitQueue queue,
DataHandler handler,
int maxParallelProcessedMsgs) |
|
DataSenderImpl(RabbitQueue queue,
int deliveryMode,
int messageConfirmBuffer) |
|
SimpleFileReceiver(RabbitQueue queue,
com.rabbitmq.client.QueueingConsumer consumer) |
|
SimpleFileSender(RabbitQueue queue) |
Copyright © 2017. All rights reserved.