org.hobbit.core.rabbit

Interface RabbitQueueFactory

All Superinterfaces:

AutoCloseable, Closeable

All Known Implementing Classes:

RabbitQueueFactoryImpl

public interface RabbitQueueFactory
extends Closeable

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.
com.rabbitmq.client.Connection	getConnection()

Methods inherited from interface java.io.Closeable

close

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

getConnection

com.rabbitmq.client.Connection getConnection()