Module: Fluent::DeadLetterQueueDropHandler

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

Instance Method Summary collapse

Instance Method Details

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



3
4
5
6
7
8
9
 
# File 'lib/fluent/plugin/dead_letter_queue_drop_handler.rb', line 3

def handle_chunk_error(out_plugin, tag, error, time, record)
  begin
    log.error("Dropping record from '#{tag}': error:#{error} time:#{time} record:#{record}")
  rescue=>e
    log.error("Error while trying to log and drop message from chunk '#{tag}' #{e.message}")
  end
end