diff --git a/lib/fluent/plugin/in_sqs.rb b/lib/fluent/plugin/in_sqs.rb index a79cb04..b0efabe 100644 --- a/lib/fluent/plugin/in_sqs.rb +++ b/lib/fluent/plugin/in_sqs.rb @@ -59,9 +59,9 @@ def run router.emit(@tag, Fluent::Engine.now, record) end - rescue - log.error 'failed to emit or receive', error: $ERROR_INFO.to_s, error_class: $ERROR_INFO.class.to_s - log.warn_backtrace $ERROR_INFO.backtrace + rescue => ex + log.error 'failed to emit or receive', error: ex.to_s, error_class: ex.class + log.warn_backtrace ex.backtrace end private