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.instrument('backends.inline.process', caller: self) { consume }
      end
    end
  end
end

Version data entries

45 entries across 45 versions & 1 rubygems

Version	Path
karafka-1.2.0	lib/karafka/backends/inline.rb
karafka-1.2.0.beta4	lib/karafka/backends/inline.rb
karafka-1.2.0.beta3	lib/karafka/backends/inline.rb
karafka-1.2.0.beta2	lib/karafka/backends/inline.rb
karafka-1.2.0.beta1	lib/karafka/backends/inline.rb