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