diff options
| author | wvengen <dev-rails@willem.engen.nl> | 2015-03-18 10:48:26 +0100 |
|---|---|---|
| committer | wvengen <dev-rails@willem.engen.nl> | 2015-09-17 22:17:39 +0200 |
| commit | 7059ab35f797c163cd8907abcd7d0830b31e56f7 (patch) | |
| tree | 708ccbf2da4412030b305f79c629a6961eb487c1 /activejob/lib/active_job/queue_adapters | |
| parent | 61f9e47feac75a2cf4ed9e092bac036294564168 (diff) | |
| download | rails-7059ab35f797c163cd8907abcd7d0830b31e56f7.tar.gz rails-7059ab35f797c163cd8907abcd7d0830b31e56f7.tar.bz2 rails-7059ab35f797c163cd8907abcd7d0830b31e56f7.zip | |
Add job priorities to ActiveJob
Diffstat (limited to 'activejob/lib/active_job/queue_adapters')
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb | 4 | ||||
| -rw-r--r-- | activejob/lib/active_job/queue_adapters/que_adapter.rb | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb b/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb index ac83da2b9c..0a785fad3b 100644 --- a/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/delayed_job_adapter.rb @@ -14,13 +14,13 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :delayed_job class DelayedJobAdapter def enqueue(job) #:nodoc: - delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name) + delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, priority: job.priority) job.provider_job_id = delayed_job.id delayed_job end def enqueue_at(job, timestamp) #:nodoc: - delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, run_at: Time.at(timestamp)) + delayed_job = Delayed::Job.enqueue(JobWrapper.new(job.serialize), queue: job.queue_name, priority: job.priority, run_at: Time.at(timestamp)) job.provider_job_id = delayed_job.id delayed_job end diff --git a/activejob/lib/active_job/queue_adapters/que_adapter.rb b/activejob/lib/active_job/queue_adapters/que_adapter.rb index 90947aa98d..ab13689747 100644 --- a/activejob/lib/active_job/queue_adapters/que_adapter.rb +++ b/activejob/lib/active_job/queue_adapters/que_adapter.rb @@ -16,13 +16,13 @@ module ActiveJob # Rails.application.config.active_job.queue_adapter = :que class QueAdapter def enqueue(job) #:nodoc: - que_job = JobWrapper.enqueue job.serialize + que_job = JobWrapper.enqueue job.serialize, priority: job.priority job.provider_job_id = que_job.attrs["job_id"] que_job end def enqueue_at(job, timestamp) #:nodoc: - que_job = JobWrapper.enqueue job.serialize, run_at: Time.at(timestamp) + que_job = JobWrapper.enqueue job.serialize, priority: job.priority, run_at: Time.at(timestamp) job.provider_job_id = que_job.attrs["job_id"] que_job end |