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