class Freddy::Adapters::MarchHareAdapter::Queue
Public Instance Methods
subscribe(manual_ack: false, &block)
click to toggle source
# File lib/freddy/adapters/march_hare_adapter.rb, line 50 def subscribe(manual_ack: false, &block) @queue.subscribe(manual_ack: manual_ack) do |meta, payload| parsed_payload = Payload.parse(payload) delivery = Delivery.new( parsed_payload, meta, meta.routing_key, meta.delivery_tag ) block.call(delivery) end end