Module: Fluent::DeadLetterQueueFileHandler

Defined in:
lib/fluent/plugin/dead_letter_queue_file_handler.rb

Instance Method Summary collapse

Instance Method Details

#handle_chunk_error(out_plugin, tag, error, time, record) ⇒ Object 



5
6
7
8
9
10
11
 
# File 'lib/fluent/plugin/dead_letter_queue_file_handler.rb', line 5

def handle_chunk_error(out_plugin, tag, error, time, record)
    begin
      @dlq_file.info({processed_at: Time.now.utc, tag: tag, error: "#{error.message}", time: time, record: record}.to_json)
    rescue=>e
      log.error("Error while trying to log and drop message from chunk '#{tag}' #{e.message}")
    end
end