Sha256: ab66815dda850e8e3711fc9aa25d0dab62ded868df0083f9e00e4c57fb860f39

Contents?: true

Size: 326 Bytes

Versions: 5

Compression:

Stored size: 326 Bytes

Contents

require 'amqp/utilities/event_loop_helper'
require 'untied-publisher/amqp/producer'

module Untied
  module Publisher
    module AMQP
      def self.start
        config.channel ||= ::AMQP::Channel.new(::AMQP.connection)
      end

      def self.producer
        Untied::Publisher::AMQP::Producer
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version Path
untied-publisher-0.0.7.pre3 lib/untied-publisher/amqp.rb
untied-publisher-0.0.7.pre2 lib/untied-publisher/amqp.rb
untied-publisher-0.0.7.pre1 lib/untied-publisher/amqp.rb
untied-publisher-0.0.7.pre lib/untied-publisher/amqp.rb
untied-publisher-0.0.6 lib/untied-publisher/amqp.rb