diff --git a/lib/rackstash/buffer.rb b/lib/rackstash/buffer.rb index 0eb7ca7..4286a17 100644 --- a/lib/rackstash/buffer.rb +++ b/lib/rackstash/buffer.rb @@ -128,7 +128,7 @@ module Rackstash # # @return [self] def clear - @messages = [] + @messages = Concurrent::Array.new @fields = Rackstash::Fields::Hash.new(forbidden_keys: FORBIDDEN_FIELDS) @tags = Rackstash::Fields::Tags.new @timestamp = nil