module Skein::Adapter

Public Instance Methods

subscribe(queue, block: true, manual_ack: true) { |payload, delivery_info, properties| ... } click to toggle source

REFACTOR: This should be converted into a proper subclass of the

various drivers that does the method re-writing at a lower level.
# File lib/skein/adapter.rb, line 7
def subscribe(queue, block: true, manual_ack: true)
  case (queue.class.to_s.split(/::/)[0])
  when 'Bunny'
    queue.subscribe(block: block, manual_ack: manual_ack) do |delivery_info, properties, payload|
      yield(payload, delivery_info[:delivery_tag], properties[:reply_to])
    end
  when 'MarchHare'
    queue.subscribe(block: block, manual_ack: manual_ack) do |metadata, payload|
      yield(payload, metadata.delivery_tag, metadata.reply_to)
    end
  end
end