diff --git a/lib/riemann/tools/riemann_client_wrapper.rb b/lib/riemann/tools/riemann_client_wrapper.rb index 58dd243e..bb1b4bba 100644 --- a/lib/riemann/tools/riemann_client_wrapper.rb +++ b/lib/riemann/tools/riemann_client_wrapper.rb @@ -25,11 +25,8 @@ def initialize(options) events << @queue.pop while !@queue.empty? && events.size < @max_bulk_size client.bulk_send(events) - rescue Riemann::Client::Error => e - warn "Dropping #{events.size} event#{'s' if events.size > 1} due to #{e}" rescue StandardError => e - warn "#{e.class} #{e}\n#{e.backtrace.join "\n"}" - Thread.main.terminate + warn "Dropping #{events.size} event#{'s' if events.size > 1} due to #{e}" end end