Contents

# frozen_string_literal: true

begin
  require 'active_job'
  require_relative 'queue_adapters/karafka_adapter'

  module ActiveJob
    # Namespace for usage simplification outside of Rails where Railtie will not kick in.
    # That way a require 'active_job/karafka' should be enough to use it
    module Karafka
    end
  end

  # We extend routing builder by adding a simple wrapper for easier jobs topics defining
  # This needs to be extended here as it is going to be used in karafka routes, hence doing that in
  # the railtie initializer would be too late
  ::Karafka::Routing::Builder.include ::Karafka::ActiveJob::RoutingExtensions
  ::Karafka::Routing::Proxy.include ::Karafka::ActiveJob::RoutingExtensions
rescue LoadError
  # We extend ActiveJob stuff in the railtie
end

Version data entries

4 entries across 4 versions & 1 rubygems

Version	Path
karafka-2.0.0.beta1	lib/active_job/karafka.rb
karafka-2.0.0.alpha6	lib/active_job/karafka.rb
karafka-2.0.0.alpha5	lib/active_job/karafka.rb
karafka-2.0.0.alpha4	lib/active_job/karafka.rb