Contents

# -*- encoding : utf-8 -*-
require 'untied/version'

require 'rubygems'
require 'bundler/setup'
require 'amqp/utilities/event_loop_helper'

module Untied
  def self.start
    Thread.abort_on_exception = false

    AMQP::Utilities::EventLoopHelper.run do
      AMQP.start
    end

    EventMachine.next_tick do
      AMQP.channel ||= AMQP::Channel.new(AMQP.connection)
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
untied-0.0.1	lib/untied.rb