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