Sha256: 538b238047dea47776b297d901dcdc90665f81a993798cbb20e880e06d557d31

Contents?: true

Size: 535 Bytes

Versions: 6

Compression:

Stored size: 535 Bytes

Contents

# frozen_string_literal: true

module Karafka
  # ActiveJob related Karafka stuff
  module ActiveJob
    # Routing extensions for ActiveJob
    module RoutingExtensions
      # This method simplifies routes definition for ActiveJob topics / queues by auto-injecting
      # the consumer class
      # @param name [String, Symbol] name of the topic where ActiveJobs jobs should go
      def active_job_topic(name)
        topic(name) do
          consumer App.config.internal.active_job.consumer
        end
      end
    end
  end
end

Version data entries

6 entries across 6 versions & 1 rubygems

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