class Freddy::Consumers::ResponseConsumer

Public Class Methods

new(logger) click to toggle source
# File lib/freddy/consumers/response_consumer.rb, line 6
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 10
def consume(_channel, queue, &block)
  @logger.debug "Consuming messages on #{queue.name}"
  queue.subscribe(&block)
end