File tree Expand file tree Collapse file tree 1 file changed +19
-7
lines changed Expand file tree Collapse file tree 1 file changed +19
-7
lines changed Original file line number Diff line number Diff line change @@ -11,15 +11,27 @@ def start(launcher)
11
11
monitor_solid_queue
12
12
end
13
13
14
- launcher . events . on_booted do
15
- @solid_queue_pid = fork do
16
- Thread . new { monitor_puma }
17
- SolidQueue ::Supervisor . start
14
+ if Gem ::Version . new ( Puma ::Const ::VERSION ) < Gem ::Version . new ( "7" )
15
+ launcher . events . on_booted do
16
+ @solid_queue_pid = fork do
17
+ Thread . new { monitor_puma }
18
+ SolidQueue ::Supervisor . start
19
+ end
20
+ end
21
+
22
+ launcher . events . on_stopped { stop_solid_queue }
23
+ launcher . events . on_restart { stop_solid_queue }
24
+ else
25
+ launcher . events . after_booted do
26
+ @solid_queue_pid = fork do
27
+ Thread . new { monitor_puma }
28
+ SolidQueue ::Supervisor . start
29
+ end
18
30
end
19
- end
20
31
21
- launcher . events . on_stopped { stop_solid_queue }
22
- launcher . events . on_restart { stop_solid_queue }
32
+ launcher . events . after_stopped { stop_solid_queue }
33
+ launcher . events . before_restart { stop_solid_queue }
34
+ end
23
35
end
24
36
25
37
private
You can’t perform that action at this time.
0 commit comments