diff options
| author | George Claghorn <george@basecamp.com> | 2018-11-11 18:23:13 -0500 |
|---|---|---|
| committer | George Claghorn <george@basecamp.com> | 2018-11-11 18:23:13 -0500 |
| commit | 14b5b5afe2bf7369499243931a88db5f40933def (patch) | |
| tree | f21b9677b8b808be535ed6eb6f0387c2dfd056b3 /app | |
| parent | a4d429f4a7c417b719270e9164634c83ded3d0ec (diff) | |
| download | rails-14b5b5afe2bf7369499243931a88db5f40933def.tar.gz rails-14b5b5afe2bf7369499243931a88db5f40933def.tar.bz2 rails-14b5b5afe2bf7369499243931a88db5f40933def.zip | |
Make job queues configurable
Diffstat (limited to 'app')
| -rw-r--r-- | app/jobs/action_mailbox/incineration_job.rb | 2 | ||||
| -rw-r--r-- | app/jobs/action_mailbox/routing_job.rb | 2 |
2 files changed, 2 insertions, 2 deletions
diff --git a/app/jobs/action_mailbox/incineration_job.rb b/app/jobs/action_mailbox/incineration_job.rb index 81b381b0d0..4fc0cb0782 100644 --- a/app/jobs/action_mailbox/incineration_job.rb +++ b/app/jobs/action_mailbox/incineration_job.rb @@ -1,5 +1,5 @@ class ActionMailbox::IncinerationJob < ActiveJob::Base - queue_as :action_mailbox_incineration + queue_as { ActionMailbox.queues[:incineration] } discard_on ActiveRecord::RecordNotFound diff --git a/app/jobs/action_mailbox/routing_job.rb b/app/jobs/action_mailbox/routing_job.rb index af4aa9f8fa..786187528a 100644 --- a/app/jobs/action_mailbox/routing_job.rb +++ b/app/jobs/action_mailbox/routing_job.rb @@ -1,5 +1,5 @@ class ActionMailbox::RoutingJob < ActiveJob::Base - queue_as :action_mailbox_routing + queue_as { ActionMailbox.queues[:routing] } def perform(inbound_email) inbound_email.route |