lib/messaging/client.rb
def declare_queue(channel, exchange, name, key, options = {})
      channel.queue(name, options) do |queue|
        # Check if additional bindings are needed
        unless default_exchange?(exchange.name)
          queue.bind(exchange, { :routing_key => key })
        end

        log.debug("Queue #{queue.name.inspect} bound to #{exchange.name.inspect}")
      end
    end
def declare_queue(channel, exchange, name, key, options = {})
      channel.queue(name, options) do |queue|
        # Check if additional bindings are needed
        unless default_exchange?(exchange.name)
          queue.bind(exchange, { :routing_key => key })
        end

        log.debug("Queue #{queue.name.inspect} bound to #{exchange.name.inspect}")
      end
    end
def declare_queue ( channel , exchange , name , key , options = { } ) channel . queue ( name , options ) do | queue | # Check if additional bindings are needed unless default_exchange? ( exchange . name ) queue . bind ( exchange , { :routing_key => key } ) end log . debug ( "Queue #{queue.name.inspect} bound to #{exchange.name.inspect}" ) end end
Declare and bind a queue to the specified exchange via the
 supplied routing key.

 @param channel [AMQP::Channel]
 @param exchange [AMQP::Exchange]
 @param name [String]
 @param key [String]
 @param options [Hash]
 @return [AMQP::Queue]
 @api public
Declare and bind a queue to the specified exchange via the supplied routing key .