class Freddy::Adapters::BunnyAdapter::Queue

Public Instance Methods

subscribe(manual_ack: false, &block) click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 51
def subscribe(manual_ack: false, &block)
  @queue.subscribe(manual_ack: manual_ack) do |info, properties, payload|
    parsed_payload = Payload.parse(payload)
    delivery = Delivery.new(
      parsed_payload, properties, info.routing_key, info.delivery_tag
    )
    block.call(delivery)
  end
end