class Taskinator::Queues::LoggedAdapter
Attributes
adapter[R]
Public Class Methods
new(adapter)
click to toggle source
# File lib/taskinator/queues.rb, line 22 def initialize(adapter) Taskinator.logger.info("Initialized '#{adapter.class.name}' queue adapter") @adapter = adapter end
Public Instance Methods
__getobj__()
click to toggle source
# File lib/taskinator/queues.rb, line 27 def __getobj__ adapter end
enqueue_create_process(definition, uuid, args)
click to toggle source
# File lib/taskinator/queues.rb, line 31 def enqueue_create_process(definition, uuid, args) Taskinator.logger.info("Enqueuing process creation for #{definition}") adapter.enqueue_create_process(definition, uuid, args) end
enqueue_process(process)
click to toggle source
# File lib/taskinator/queues.rb, line 36 def enqueue_process(process) Taskinator.logger.info("Enqueuing process #{process}") adapter.enqueue_process(process) end
enqueue_task(task)
click to toggle source
# File lib/taskinator/queues.rb, line 41 def enqueue_task(task) Taskinator.logger.info("Enqueuing task #{task}") adapter.enqueue_task(task) end