Class: RocketJob::Subscribers::Server
Instance Attribute Summary collapse
Instance Method Summary
collapse
#process_action, #process_event, test_mode!, test_mode?
Constructor Details
#initialize(supervisor) ⇒ Server
Returns a new instance of Server.
8
9
10
|
# File 'lib/rocket_job/subscribers/server.rb', line 8
def initialize(supervisor)
@supervisor = supervisor
end
|
Instance Attribute Details
#supervisor ⇒ Object
Returns the value of attribute supervisor.
6
7
8
|
# File 'lib/rocket_job/subscribers/server.rb', line 6
def supervisor
@supervisor
end
|
Instance Method Details
#kill(server_id: nil, name: nil, wait_timeout: 3) ⇒ Object
12
13
14
15
16
17
18
19
20
21
22
23
|
# File 'lib/rocket_job/subscribers/server.rb', line 12
def kill(server_id: nil, name: nil, wait_timeout: 3)
return unless my_server?(server_id, name)
supervisor.synchronize do
supervisor.worker_pool.stop
supervisor.worker_pool.join(wait_timeout)
supervisor.worker_pool.kill
end
Supervisor.shutdown!
logger.info "Killed"
end
|
#pause(server_id: nil, name: nil) ⇒ Object
25
26
27
28
29
30
31
|
# File 'lib/rocket_job/subscribers/server.rb', line 25
def pause(server_id: nil, name: nil)
return unless my_server?(server_id, name)
supervisor.synchronize { supervisor.server.pause! if supervisor.server.may_pause? }
Supervisor.event!
logger.info "Paused"
end
|
#refresh(server_id: nil, name: nil) ⇒ Object
33
34
35
36
37
38
|
# File 'lib/rocket_job/subscribers/server.rb', line 33
def refresh(server_id: nil, name: nil)
return unless my_server?(server_id, name)
Supervisor.event!
logger.info "Refreshed"
end
|
#resume(server_id: nil, name: nil) ⇒ Object
40
41
42
43
44
45
46
|
# File 'lib/rocket_job/subscribers/server.rb', line 40
def resume(server_id: nil, name: nil)
return unless my_server?(server_id, name)
supervisor.synchronize { supervisor.server.resume! if supervisor.server.may_resume? }
Supervisor.event!
logger.info "Resumed"
end
|
#stop(server_id: nil, name: nil) ⇒ Object
48
49
50
51
52
53
|
# File 'lib/rocket_job/subscribers/server.rb', line 48
def stop(server_id: nil, name: nil)
return unless my_server?(server_id, name)
Supervisor.shutdown!
logger.info "Shutdown"
end
|
#thread_dump(server_id: nil, name: nil) ⇒ Object
55
56
57
58
59
60
|
# File 'lib/rocket_job/subscribers/server.rb', line 55
def thread_dump(server_id: nil, name: nil)
return unless my_server?(server_id, name)
logger.info "Thread dump"
supervisor.worker_pool.log_backtraces
end
|