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