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