class Freddy::Adapters::BunnyAdapter::Queue

Public Class Methods

new(queue) click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 58
def initialize(queue)
  @queue = queue
end

Public Instance Methods

bind(*args) click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 62
def bind(*args)
  @queue.bind(*args)
  self
end
message_count() click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 71
def message_count
  @queue.message_count
end
name() click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 67
def name
  @queue.name
end
subscribe(manual_ack: false) { |delivery| ... } click to toggle source
# File lib/freddy/adapters/bunny_adapter.rb, line 75
def subscribe(manual_ack: false)
  @queue.subscribe(manual_ack: manual_ack) do |info, properties, payload|
    parsed_payload = Payload.parse(payload, properties[:content_encoding])
    delivery = Delivery.new(
      parsed_payload, properties, info.routing_key, info.delivery_tag, info.exchange
    )
    yield(delivery)
  end
end