org.hobbit.core.rabbit

Class RabbitQueueFactoryImpl

java.lang.Object

org.hobbit.core.rabbit.RabbitQueueFactoryImpl

All Implemented Interfaces:

Closeable, AutoCloseable, RabbitQueueFactory

public class RabbitQueueFactoryImpl
extends Object
implements RabbitQueueFactory, Closeable

Field Summary

Fields

Modifier and Type	Field and Description
private com.rabbitmq.client.Connection	connection

Constructor Summary

Constructors

Constructor and Description
RabbitQueueFactoryImpl(com.rabbitmq.client.Connection connection)

Method Summary

Modifier and Type	Method and Description
void	close()
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 class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connection

private final com.rabbitmq.client.Connection connection

Constructor Detail

RabbitQueueFactoryImpl

public RabbitQueueFactoryImpl(com.rabbitmq.client.Connection connection)

Method Detail

createDefaultRabbitQueue

public RabbitQueue createDefaultRabbitQueue(String name)
                                     throws IOException

Description copied from interface: RabbitQueueFactory

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.

Specified by:

createDefaultRabbitQueue in interface RabbitQueueFactory

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

public com.rabbitmq.client.Connection getConnection()

Specified by:

getConnection in interface RabbitQueueFactory

close

public void close()
           throws IOException

Specified by:

close in interface Closeable

Specified by:

close in interface AutoCloseable

Throws:

IOException