Package org.hobbit.core.rabbit

Interface RabbitQueueFactory

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      com.rabbitmq.client.Channel createChannel()
      This method opens a channel using the established connection to RabbitMQ.
      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. 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 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.
      com.rabbitmq.client.Connection getConnection()
      Returns the Connection to the RabbitMQ broker used internally.

    • 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

      • createDefaultRabbitQueue

        RabbitQueue createDefaultRabbitQueue​(String name,
                                     com.rabbitmq.client.Channel channel)
                              throws IOException
        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.
        Parameters:
        name - name of the queue
        channel - the Channel that will be used to generate 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

      • createChannel

        com.rabbitmq.client.Channel createChannel()
                                   throws IOException
        This method opens a channel using the established connection to RabbitMQ. The channel number is automatically derived from the connection.
        Returns:
        the newly created Channel
        Throws:
        IOException - if a communication problem during the creation of the channel

      • getConnection

        com.rabbitmq.client.Connection getConnection()
        Returns the Connection to the RabbitMQ broker used internally.
        Returns:
        the Connection to the RabbitMQ broker used internally