class Legion::Transport::Messages::TaskLog

Public Instance Methods

exchange() click to toggle source
# File lib/legion/transport/messages/task_log.rb, line 11
def exchange
  Legion::Transport::Exchanges::Task
end
generate_task?() click to toggle source
# File lib/legion/transport/messages/task_log.rb, line 21
def generate_task?
  false
end
message() click to toggle source
# File lib/legion/transport/messages/task_log.rb, line 15
def message
  @options[:function] = 'add_log'
  @options[:runner_class] = 'Legion::Extensions::Tasker::Runners::Log'
  @options
end
routing_key() click to toggle source
# File lib/legion/transport/messages/task_log.rb, line 7
def routing_key
  "task.logs.create.#{@options[:task_id]}"
end
validate() click to toggle source
# File lib/legion/transport/messages/task_log.rb, line 25
def validate
  @options[:task_id] = @options[:task_id].to_i if @options[:task_id].is_a? String
  unless @options[:task_id].is_a? Integer
    raise "task_id must be an integer but is #{@options[:task_id].class}(#{@options[:task_id]})"
  end

  @valid = true
end