Class: MissionControl::Jobs::Server

Inherits:
Object
  • Object
show all
Includes:
IdentifiedByName, RecurringTasks, Serializable, Workers
Defined in:
lib/mission_control/jobs/server.rb

Defined Under Namespace

Modules: RecurringTasks, Serializable, Workers

Instance Attribute Summary collapse

Instance Method Summary collapse

Methods included from Serializable

#to_global_id

Methods included from RecurringTasks

#find_recurring_task, #recurring_tasks

Methods included from Workers

#find_worker, #workers_relation

Methods included from IdentifiedByName

#id

Constructor Details

#initialize(name:, queue_adapter:, application:, backtrace_cleaner: nil) ⇒ Server

Returns a new instance of Server.



9
10
11
12
13
14
 
# File 'lib/mission_control/jobs/server.rb', line 9

def initialize(name:, queue_adapter:, application:, backtrace_cleaner: nil)
  super(name: name)
  @queue_adapter = queue_adapter
  @application = application
  @backtrace_cleaner = backtrace_cleaner || MissionControl::Jobs.backtrace_cleaner
end

Instance Attribute Details

#application ⇒ Object (readonly)

Returns the value of attribute application.



7
8
9
 
# File 'lib/mission_control/jobs/server.rb', line 7

def application
  @application
end

#backtrace_cleaner ⇒ Object (readonly)

Returns the value of attribute backtrace_cleaner.



7
8
9
 
# File 'lib/mission_control/jobs/server.rb', line 7

def backtrace_cleaner
  @backtrace_cleaner
end

#name ⇒ Object (readonly)

Returns the value of attribute name.



7
8
9
 
# File 'lib/mission_control/jobs/server.rb', line 7

def name
  @name
end

#queue_adapter ⇒ Object (readonly)

Returns the value of attribute queue_adapter.



7
8
9
 
# File 'lib/mission_control/jobs/server.rb', line 7

def queue_adapter
  @queue_adapter
end

Instance Method Details

#activating(&block) ⇒ Object 



16
17
18
19
20
21
22
 
# File 'lib/mission_control/jobs/server.rb', line 16

def activating(&block)
  previous_adapter = ActiveJob::Base.current_queue_adapter
  ActiveJob::Base.current_queue_adapter = queue_adapter
  queue_adapter.activating(&block)
ensure
  ActiveJob::Base.current_queue_adapter = previous_adapter
end

#queue_adapter_name ⇒ Object 



24
25
26
 
# File 'lib/mission_control/jobs/server.rb', line 24

def queue_adapter_name
  ActiveJob.adapter_name(queue_adapter).underscore.to_sym
end