Contents

# frozen_string_literal: true

module Karafka
  # Namespace for all different backends Karafka supports
  module Backends
    # Backend that just runs stuff asap without any scheduling
    module Inline
      private

      # Executes perform code immediately (without enqueuing)
      def process
        Karafka.monitor.notice(self.class, params_batch)
        perform
      end
    end
  end
end

Version data entries

3 entries across 3 versions & 1 rubygems

Version	Path
karafka-1.0.1	lib/karafka/backends/inline.rb
karafka-1.0.0	lib/karafka/backends/inline.rb
karafka-1.0.0.rc1	lib/karafka/backends/inline.rb