Class: QueueBus::Adapters::Data
- Inherits:
-
Base
- Object
- Base
- QueueBus::Adapters::Data
show all
- Defined in:
- lib/queue_bus/adapters/data.rb
Instance Attribute Summary collapse
Instance Method Summary
collapse
Methods inherited from Base
#initialize
Instance Attribute Details
#redis(&block) ⇒ Object
13
14
15
16
17
|
# File 'lib/queue_bus/adapters/data.rb', line 13
def redis(&block)
raise 'no redis instance set' unless @redis
block.call(@redis)
end
|
Instance Method Details
#enabled! ⇒ Object
7
8
9
|
# File 'lib/queue_bus/adapters/data.rb', line 7
def enabled!
end
|
#enqueue(queue_name, klass, json) ⇒ Object
19
20
21
|
# File 'lib/queue_bus/adapters/data.rb', line 19
def enqueue(queue_name, klass, json)
push(queue_name, class: klass.to_s, args: [json])
end
|
#enqueue_at(epoch_seconds, queue_name, klass, json) ⇒ Object
23
24
25
26
|
# File 'lib/queue_bus/adapters/data.rb', line 23
def enqueue_at(epoch_seconds, queue_name, klass, json)
item = delayed_job_to_hash_with_queue(queue_name, klass, [json])
delayed_push(epoch_seconds, item)
end
|
#setup_heartbeat!(_queue_name) ⇒ Object
28
29
30
|
# File 'lib/queue_bus/adapters/data.rb', line 28
def setup_heartbeat!(_queue_name)
raise NotImplementedError
end
|