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