class Kuroko2::Workflow::Task::Queue

Public Instance Methods

execute() click to toggle source
# File lib/autoload/kuroko2/workflow/task/queue.rb, line 5
def execute
  if option.present?
    token.context['QUEUE'] = option
  else
    token.context['QUEUE'] = Execution::DEFAULT_QUEUE
  end

  :next
end
validate() click to toggle source
# File lib/autoload/kuroko2/workflow/task/queue.rb, line 15
def validate
  unless /\A\@?[\w-]{1,180}\z/ === option
    raise Workflow::AssertionError, "Queue name must be match with /\A\@?[\w-]{1,255}\z/: #{option}"
  end

  unless Worker.where(queue: option, working: true).exists?
    raise Workflow::AssertionError, "No such queue : #{option}"
  end
end