Contents

# frozen_string_literal: true

require 'resque'
require 'emittance'

require 'emittance/resque/version'
require 'emittance/resque/errors'

require 'emittance/resque/broker'
require 'emittance/resque/dispatcher'

module Emittance
  ##
  # Top-level namespace for the Resque emittance broker.
  #
  module Resque
    class << self
      def use_serializer(serializer)
        Emittance::Resque::EventSerializer.use_serializer serializer
      end

      def default_queue
        Emittance::Resque::Dispatcher.default_queue
      end

      def default_queue=(queue)
        Emittance::Resque::Dispatcher.default_queue = queue
      end
    end
  end
end

# :nocov:
Emittance::Brokerage.register_broker Emittance::Resque::Broker, :resque

if defined?(ActiveRecord)
  require 'emittance/resque/event_serializer/active_record'
  Emittance::Resque.use_serializer Emittance::Resque::EventSerializer::ActiveRecord
else
  Emittance::Resque.use_serializer Emittance::Resque::EventSerializer::Default
end
# :nocov:

Version data entries

2 entries across 2 versions & 1 rubygems

Version	Path
emittance-resque-1.1.0	lib/emittance/resque.rb
emittance-resque-1.0.0	lib/emittance/resque.rb