@@ -0,0 +1,7 @@ |
||
1 |
+class AgentCleanupExpiredJob < ActiveJob::Base |
|
2 |
+ queue_as :default |
|
3 |
+ |
|
4 |
+ def perform |
|
5 |
+ Event.cleanup_expired! |
|
6 |
+ end |
|
7 |
+end |
@@ -0,0 +1,7 @@ |
||
1 |
+class AgentPropagateJob < ActiveJob::Base |
|
2 |
+ queue_as :default |
|
3 |
+ |
|
4 |
+ def perform |
|
5 |
+ Agent.receive! |
|
6 |
+ end |
|
7 |
+end |
@@ -0,0 +1,7 @@ |
||
1 |
+class AgentRunScheduleJob < ActiveJob::Base |
|
2 |
+ queue_as :default |
|
3 |
+ |
|
4 |
+ def perform(time) |
|
5 |
+ Agent.run_schedule(time) |
|
6 |
+ end |
|
7 |
+end |
@@ -149,21 +149,21 @@ class HuginnScheduler < LongRunnable::Worker |
||
149 | 149 |
def run_schedule(time) |
150 | 150 |
with_mutex do |
151 | 151 |
puts "Queuing schedule for #{time}" |
152 |
- Agent.delay.run_schedule(time) |
|
152 |
+ AgentRunScheduleJob.perform_later(time) |
|
153 | 153 |
end |
154 | 154 |
end |
155 | 155 |
|
156 | 156 |
def propagate! |
157 | 157 |
with_mutex do |
158 | 158 |
puts "Queuing event propagation" |
159 |
- Agent.delay.receive! |
|
159 |
+ AgentPropagateJob.perform_later |
|
160 | 160 |
end |
161 | 161 |
end |
162 | 162 |
|
163 | 163 |
def cleanup_expired_events! |
164 | 164 |
with_mutex do |
165 | 165 |
puts "Running event cleanup" |
166 |
- Event.delay.cleanup_expired! |
|
166 |
+ AgentCleanupExpiredJob.perform_later |
|
167 | 167 |
end |
168 | 168 |
end |
169 | 169 |
|