Class: Freddy::Consumers::ResponseConsumer

Inherits:

Object

Object
Freddy::Consumers::ResponseConsumer

show all

Defined in:: lib/freddy/consumers/response_consumer.rb

Instance Method Summary collapse

#consume(_channel, queue, &block) ⇒ Object
#initialize(logger) ⇒ ResponseConsumer constructor

A new instance of ResponseConsumer.

Constructor Details

#initialize(logger) ⇒ `ResponseConsumer`

Returns a new instance of ResponseConsumer.



6
7
8

# File 'lib/freddy/consumers/response_consumer.rb', line 6

def initialize(logger)
  @logger = logger
end

Instance Method Details

#consume(_channel, queue, &block) ⇒ `Object`

# 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