Class: Karafka::Pro::Processing::Jobs::RevokedNonBlocking

Inherits:
Karafka::Processing::Jobs::Revoked show all
Defined in:
lib/karafka/pro/processing/jobs/revoked_non_blocking.rb

Overview

The revoked job type in a non-blocking variant. This variant works “like” the regular revoked but does not block the queue.

It can be useful when having long lasting jobs that would exceed max.poll.interval in scenarios where there are more jobs than threads, without this being async we would potentially stop polling

Instance Attribute Summary

Attributes inherited from Karafka::Processing::Jobs::Base

#executor

Instance Method Summary collapse

Methods inherited from Karafka::Processing::Jobs::Revoked

#before_schedule, #call

Methods inherited from Karafka::Processing::Jobs::Base

#after_call, #before_call, #before_schedule, #call, #finish!, #finished?, #non_blocking?, #wrap

Constructor Details

#initialize(*args) ⇒ RevokedNonBlocking

Makes this job non-blocking from the start

Parameters:

  • args (Array) —

    any arguments accepted by ::Karafka::Processing::Jobs::Revoked



23
24
25
26
 
# File 'lib/karafka/pro/processing/jobs/revoked_non_blocking.rb', line 23

def initialize(*args)
  super
  @non_blocking = true
end