Contents

# frozen_string_literal: true

require 'logger'
require 'forwardable'
require 'bunny'
require 'jackhammer/log'
require 'jackhammer/null_exception_adapter'
require 'jackhammer/configuration'
require 'jackhammer/message_receiver'
require 'jackhammer/queue'
require 'jackhammer/topic'
require 'jackhammer/topic_manager'
require 'jackhammer/publish'
require 'jackhammer/server'

module Jackhammer
  class << self
    attr_accessor :configuration
    attr_writer :connection

    def configure
      @configuration = Configuration.instance
      yield @configuration
    end

    def connection
      @connection ||= Bunny.new(
        Jackhammer.configuration.connection_url,
        Jackhammer.configuration.connection_options
      ).start
    end

    def channel
      @channel ||= connection.create_channel
    end

    def topics
      @topics ||= TopicManager.topics
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
jackhammer-0.1.0	lib/jackhammer.rb