diff --git a/app/jobs/conversations/update_message_status_job.rb b/app/jobs/conversations/update_message_status_job.rb index 6fcef4361..efe2937b4 100644 --- a/app/jobs/conversations/update_message_status_job.rb +++ b/app/jobs/conversations/update_message_status_job.rb @@ -1,5 +1,5 @@ class Conversations::UpdateMessageStatusJob < ApplicationJob - queue_as :low + queue_as :deferred # This job only support marking messages as read or delivered, update this array if we want to support more statuses VALID_STATUSES = %w[read delivered].freeze diff --git a/config/sidekiq.yml b/config/sidekiq.yml index af813d92a..d2d764382 100644 --- a/config/sidekiq.yml +++ b/config/sidekiq.yml @@ -23,6 +23,7 @@ - action_mailbox_routing - low - scheduled_jobs + - deferred - housekeeping - async_database_migration - active_storage_analysis diff --git a/spec/jobs/conversations/update_message_status_job_spec.rb b/spec/jobs/conversations/update_message_status_job_spec.rb index ff5c90292..508d2dc1c 100644 --- a/spec/jobs/conversations/update_message_status_job_spec.rb +++ b/spec/jobs/conversations/update_message_status_job_spec.rb @@ -10,7 +10,7 @@ RSpec.describe Conversations::UpdateMessageStatusJob do it 'enqueues the job' do expect { job }.to have_enqueued_job(described_class) .with(conversation.id, conversation.contact_last_seen_at, :read) - .on_queue('low') + .on_queue('deferred') end context 'when called' do