class Freddy::Adapters::BunnyAdapter::Queue
Public Class Methods
Source
# File lib/freddy/adapters/bunny_adapter.rb, line 58 def initialize(queue) @queue = queue end
Public Instance Methods
Source
# File lib/freddy/adapters/bunny_adapter.rb, line 62 def bind(*) @queue.bind(*) self end
Source
# File lib/freddy/adapters/bunny_adapter.rb, line 71 def message_count @queue.message_count end
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