Contents

module RabbitFeed
  class Connection
    include Singleton

    def initialize
      RabbitFeed.log.info { { event: :connecting_to_rabbitmq, options: RabbitFeed.configuration.connection_options.merge(password: :redacted, logger: :redacted) } }
      @connection = Bunny.new RabbitFeed.configuration.connection_options
      @connection.start
      RabbitFeed.log.info { { event: :connected_to_rabbitmq } }
      @channel = @connection.create_channel
      @mutex = Mutex.new
    end

    private

    attr_reader :channel, :mutex

    def synchronized
      mutex.synchronize do
        yield
      end
    end

    def connection_in_use?
      mutex.locked?
    end
  end
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
rabbit_feed-3.0.3	lib/rabbit_feed/connection.rb
rabbit_feed-3.0.2	lib/rabbit_feed/connection.rb
rabbit_feed-3.0.1	lib/rabbit_feed/connection.rb
rabbit_feed-3.0.0	lib/rabbit_feed/connection.rb