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 consume code immediately (without enqueuing)
      def process
        Karafka.monitor.notice(self.class, params_batch)
        consume
      end
    end
  end
end

Version data entries

5 entries across 5 versions & 1 rubygems

Version	Path
karafka-1.1.2	lib/karafka/backends/inline.rb
karafka-1.1.1	lib/karafka/backends/inline.rb
karafka-1.1.0	lib/karafka/backends/inline.rb
karafka-1.1.0.alpha2	lib/karafka/backends/inline.rb
karafka-1.1.0.alpha1	lib/karafka/backends/inline.rb