Contents

require "harmoniser/channelable"
require "harmoniser/definition"

module Harmoniser
  class Topology
    include Channelable

    attr_reader :bindings, :exchanges, :queues

    def initialize
      @bindings = Set.new
      @exchanges = Set.new
      @queues = Set.new
    end

    def add_exchange(type, name, **opts)
      @exchanges << Definition::Exchange.new(
        type: type,
        name: name,
        opts: opts
      )
    end

    def add_queue(name, **opts)
      @queues << Definition::Queue.new(
        name: name,
        opts: opts
      )
    end

    def add_binding(exchange_name, destination_name, destination_type = :queue, **opts)
      @bindings << Definition::Binding.new(
        exchange_name: exchange_name,
        destination_name: destination_name,
        destination_type: destination_type,
        opts: opts
      )
    end

    def declare
      channel = self.class.create_channel
      declare_exchanges(channel)
      declare_queues(channel)
      declare_bindings(channel)
      Harmoniser.connection.close
    end

    private

    def declare_exchanges(channel)
      exchanges.each do |exchange|
        Bunny::Exchange.new(channel, exchange.type, exchange.name, exchange.opts)
      end
    end

    def declare_queues(channel)
      queues.each do |queue|
        Bunny::Queue.new(channel, queue.name, queue.opts)
      end
    end

    def declare_bindings(channel)
      bindings.each do |binding|
        if binding.queue?
          channel.queue_bind(binding.destination_name, binding.exchange_name, binding.opts)
        elsif binding.exchange?
          ;
        end
      end
    end
  end
end

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
harmoniser-0.2.0	lib/harmoniser/topology.rb
harmoniser-0.1.0	lib/harmoniser/topology.rb