Class: Taskinator::Queues::LoggedAdapter

Inherits:
Delegator
  • Object
show all
Defined in:
lib/taskinator/queues.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(adapter) ⇒ LoggedAdapter

Returns a new instance of LoggedAdapter.



16
17
18
19
 
# File 'lib/taskinator/queues.rb', line 16

def initialize(adapter)
  Taskinator.logger.info("Initialized '#{adapter.class.name}' queue adapter")
  @adapter = adapter
end

Instance Attribute Details

#adapter ⇒ Object (readonly)

Returns the value of attribute adapter.



14
15
16
 
# File 'lib/taskinator/queues.rb', line 14

def adapter
  @adapter
end

Instance Method Details

#__getobj__ ⇒ Object 



21
22
23
 
# File 'lib/taskinator/queues.rb', line 21

def __getobj__
  adapter
end

#enqueue_job(job) ⇒ Object 



35
36
37
38
 
# File 'lib/taskinator/queues.rb', line 35

def enqueue_job(job)
  Taskinator.logger.info("Enqueuing job #{job}")
  adapter.enqueue_job(job)
end

#enqueue_process(process) ⇒ Object 



25
26
27
28
 
# File 'lib/taskinator/queues.rb', line 25

def enqueue_process(process)
  Taskinator.logger.info("Enqueuing process #{process}")
  adapter.enqueue_process(process)
end

#enqueue_task(task) ⇒ Object 



30
31
32
33
 
# File 'lib/taskinator/queues.rb', line 30

def enqueue_task(task)
  Taskinator.logger.info("Enqueuing task #{task}")
  adapter.enqueue_task(task)
end