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