allow setting sidekiq worker class

This commit is contained in:
Konstantin Haase 2015-10-30 16:29:09 +01:00
parent 4035b22bf6
commit 9c9aa3334c
2 changed files with 4 additions and 3 deletions

View File

@ -1,6 +1,6 @@
module Travis::API::V3
class Queries::User < Query
set_queue(:user_sync, :user_sync)
setup_sidekiq(:user_sync, queue: :user_sync, class_name: "Travis::GithubSync::Workers::SyncUser")
params :id, :login, :email, :github_id, :is_syncing
def find

View File

@ -9,8 +9,9 @@ module Travis::API::V3
]
end
def self.set_queue(identifier, queue)
sidekiq_queue(identifier)[1] = queue
def self.setup_sidekiq(identifier, queue: nil, class_name: nil)
sidekiq_queue(identifier)[0] = class_name if class_name
sidekiq_queue(identifier)[1] = queue if queue
end
# generate from eval to avoid additional string allocations on every params access