class Fluent::Plugin::AMQPOutput::HeaderElement
Public Instance Methods
getNestedValue(data, path)
click to toggle source
# File lib/fluent/plugin/out_amqp.rb, line 80 def getNestedValue(data, path) temp_data = data temp_path = path.dup until temp_data.nil? or temp_path.empty? temp_data = temp_data[temp_path.shift] end temp_data end
getValue(data)
click to toggle source
Extract a header and value from the input data returning nil if value cannot be derived
# File lib/fluent/plugin/out_amqp.rb, line 74 def getValue(data) val = getNestedValue(data, @source ) if @source val ||= @default if @default val end