class Freddy::Consumers::ResponseConsumer

Public Class Methods

new(logger) click to toggle source
# File lib/freddy/consumers/response_consumer.rb, line 4
def initialize(logger)
  @logger = logger
end

Public Instance Methods

consume(channel, queue, &block) click to toggle source
# File lib/freddy/consumers/response_consumer.rb, line 8
def consume(channel, queue, &block)
  @logger.debug "Consuming messages on #{queue.name}"
  queue.subscribe do |delivery|
    block.call(delivery)
  end
end