Contents

require 'amqp'

module Rodent
  class Server
    class << self
      attr_accessor :settings

      def configure(&block)
        @settings ||= {}
        yield
      end

      def set(attr, value)
        settings[attr] = value
      end

      def run(&block)
        EM.run do
          AMQP.connection ||= AMQP.connect(settings[:connection])

          block.call.each(&:bind)
        end
      end

      def stop
        AMQP.connection.close { EM.stop }
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
rodent-0.0.7	lib/rodent/server.rb
rodent-0.0.6	lib/rodent/server.rb
rodent-0.0.4	lib/rodent/server.rb
rodent-0.0.3	lib/rodent/server.rb
rodent-0.0.2	lib/rodent/server.rb