Class: ActiveJob::QueueAdapters::KarafkaAdapter

Inherits:

Object

• Object
• ActiveJob::QueueAdapters::KarafkaAdapter

Defined in:

lib/active_job/queue_adapters/karafka_adapter.rb

Overview

Karafka adapter for enqueuing jobs This is here for ease of integration with ActiveJob.

Instance Method Summary

• #enqueue(job) ⇒ Object

  Enqueues the job using the configured dispatcher.

• #enqueue_at(_job, _timestamp) ⇒ Object

  Raises info, that Karafka backend does not support scheduling jobs.

Instance Method Details

#enqueue(job) ⇒ Object

Enqueues the job using the configured dispatcher

Parameters:

• job (Object) —

  job that should be enqueued

# File 'lib/active_job/queue_adapters/karafka_adapter.rb', line 13

def enqueue(job)
  ::Karafka::App.config.internal.active_job.dispatcher.call(job)
end

#enqueue_at(_job, _timestamp) ⇒ Object

Raises info, that Karafka backend does not support scheduling jobs

Parameters:

• _job (Object) —

  job we cannot enqueue

• _timestamp (Time) —

  time when job should run

Raises:

• (NotImplementedError)

# File 'lib/active_job/queue_adapters/karafka_adapter.rb', line 21

def enqueue_at(_job, _timestamp)
  raise NotImplementedError, 'This queueing backend does not support scheduling jobs.'
end