|
1 | 1 | module ActiveJob
|
2 | 2 | module QueueAdapters
|
3 |
| - class BarbequeAdapter |
4 |
| - # Interface for ActiveJob 5.0 |
| 3 | + class BarbequeAdapter < ActiveJob::AbstractAdapter |
5 | 4 | def enqueue(job)
|
6 |
| - BarbequeAdapter.enqueue(job) |
| 5 | + execution = BarbequeClient.enqueue( |
| 6 | + job: job.class.to_s, |
| 7 | + message: ActiveJob::Arguments.serialize(job.arguments), |
| 8 | + queue: job.queue_name, |
| 9 | + ) |
| 10 | + job.job_id = execution.message_id |
7 | 11 | end
|
8 | 12 |
|
9 | 13 | def enqueue_at(job, timestamp)
|
10 |
| - BarbequeAdapter.enqueue_at(job, timestamp) |
11 |
| - end |
12 |
| - |
13 |
| - class << self |
14 |
| - # Interface for ActiveJob 4.2 |
15 |
| - def enqueue(job) |
16 |
| - execution = BarbequeClient.enqueue( |
17 |
| - job: job.class.to_s, |
18 |
| - message: ActiveJob::Arguments.serialize(job.arguments), |
19 |
| - queue: job.queue_name, |
20 |
| - ) |
21 |
| - job.job_id = execution.message_id |
22 |
| - end |
23 |
| - |
24 |
| - def enqueue_at(job, timestamp) |
25 |
| - delay_seconds = (timestamp - Time.now.to_f).round |
26 |
| - execution = BarbequeClient.enqueue( |
27 |
| - job: job.class.to_s, |
28 |
| - message: ActiveJob::Arguments.serialize(job.arguments), |
29 |
| - queue: job.queue_name, |
30 |
| - delay_seconds: delay_seconds, |
31 |
| - ) |
32 |
| - job.job_id = execution.message_id |
33 |
| - end |
| 14 | + delay_seconds = (timestamp - Time.now.to_f).round |
| 15 | + execution = BarbequeClient.enqueue( |
| 16 | + job: job.class.to_s, |
| 17 | + message: ActiveJob::Arguments.serialize(job.arguments), |
| 18 | + queue: job.queue_name, |
| 19 | + delay_seconds: delay_seconds, |
| 20 | + ) |
| 21 | + job.job_id = execution.message_id |
34 | 22 | end
|
35 | 23 | end
|
36 | 24 | end
|
|
0 commit comments