org.hobbit.core.components

Interface RabbitQueueFactory

All Known Subinterfaces:

PlatformConnector

All Known Implementing Classes:

AbstractBenchmarkController, AbstractCommandReceivingComponent, AbstractComponent, AbstractDataGenerator, AbstractEvaluationModule, AbstractEvaluationStorage, AbstractPlatformConnectorComponent, AbstractSequencingTaskGenerator, AbstractSystemAdapter, AbstractTaskGenerator, InMemoryEvaluationStore

public interface RabbitQueueFactory

Method Summary

Modifier and Type	Method and Description
RabbitQueue	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.

Method Detail

createDefaultRabbitQueue

RabbitQueue createDefaultRabbitQueue(String name)
                              throws IOException

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.

Parameters:

name - name of the queue

Returns:

RabbitQueue object comprising the Channel and the name of the created queue

Throws:

IOException - if a communication problem during the creation of the channel or the queue occurs