about summary refs log tree commit diff
path: root/app/workers/notification_worker.rb
diff options
context:
space:
mode:
authorEugen Rochko <eugen@zeonfederated.com>2017-04-04 00:53:20 +0200
committerEugen Rochko <eugen@zeonfederated.com>2017-04-04 00:53:20 +0200
commitf722bd2387df9163760014e9555928ec487ae95f (patch)
tree77ffecc4b48f924dbf49a0f179640850dd5a365b /app/workers/notification_worker.rb
parent8232f76c482d3046055bd7bf224ef7835d0fa399 (diff)
Separate background jobs into different queues. ATTENTION: new queue "pull"
must be added to the Sidekiq invokation in your systemd file

The pull queue will handle link crawling, thread resolving, and OStatus
processing. Such tasks are more likely to hang for a longer time (due to
network requests) so it is more sensible to not make the "in-house" tasks
wait for them.
Diffstat (limited to 'app/workers/notification_worker.rb')
-rw-r--r--app/workers/notification_worker.rb2
1 files changed, 1 insertions, 1 deletions
diff --git a/app/workers/notification_worker.rb b/app/workers/notification_worker.rb
index 1a2faefd8..da1d6ab45 100644
--- a/app/workers/notification_worker.rb
+++ b/app/workers/notification_worker.rb
@@ -3,7 +3,7 @@
 class NotificationWorker
   include Sidekiq::Worker
 
-  sidekiq_options retry: 5
+  sidekiq_options queue: 'push', retry: 5
 
   def perform(xml, source_account_id, target_account_id)
     SendInteractionService.new.call(xml, Account.find(source_account_id), Account.find(target_account_id))