Sha256: 88e2bd8c8ff726bbdf9bce2943d9149a9445c8b48116454d12e38ae0aeed51f6
Contents?: true
Size: 1.46 KB
Versions: 15
Compression:
Stored size: 1.46 KB
Contents
require 'bunny'
class Freddy
module Adapters
class BunnyAdapter
def self.connect(config)
bunny = Bunny.new(config)
bunny.start
new(bunny)
end
def initialize(bunny)
@bunny = bunny
end
def create_channel(prefetch: nil)
bunny_channel = @bunny.create_channel
bunny_channel.prefetch(prefetch) if prefetch
Channel.new(bunny_channel)
end
def close
@bunny.close
end
class Channel
extend Forwardable
NO_ROUTE = 312
def initialize(channel)
@channel = channel
end
def_delegators :@channel, :topic, :default_exchange, :consumers, :acknowledge
def queue(*args)
Queue.new(@channel.queue(*args))
end
def on_no_route(&block)
default_exchange.on_return do |return_info, properties, content|
if return_info[:reply_code] == NO_ROUTE
block.call(properties[:correlation_id])
end
end
end
end
class Queue < Shared::Queue
def subscribe(manual_ack: false, &block)
@queue.subscribe(manual_ack: manual_ack) do |info, properties, payload|
parsed_payload = Payload.parse(payload)
delivery = Delivery.new(
parsed_payload, properties, info.routing_key, info.delivery_tag
)
block.call(delivery)
end
end
end
end
end
end
Version data entries
15 entries across 15 versions & 2 rubygems