Class: RailsConsolePro::Services::QueueInsightFetcher

Inherits:
Object
  • Object
show all
Defined in:
lib/rails_console_pro/services/queue_insight_fetcher.rb

Defined Under Namespace

Modules: Adapters

Constant Summary collapse

DEFAULT_LIMIT = 
20

Instance Method Summary collapse

Constructor Details

#initialize(queue_adapter = nil) ⇒ QueueInsightFetcher

Returns a new instance of QueueInsightFetcher.



8
9
10
 
# File 'lib/rails_console_pro/services/queue_insight_fetcher.rb', line 8

def initialize(queue_adapter = nil)
  @queue_adapter = queue_adapter
end

Instance Method Details

#fetch(limit: DEFAULT_LIMIT, queue: nil) ⇒ Object 



12
13
14
15
16
17
18
 
# File 'lib/rails_console_pro/services/queue_insight_fetcher.rb', line 12

def fetch(limit: DEFAULT_LIMIT, queue: nil)
  adapter = build_adapter(@queue_adapter || detect_active_job_adapter)
  return nil unless adapter

  safe_limit = normalize_limit(limit)
  adapter.fetch(limit: safe_limit, queue: queue)
end