Merge pull request #3406 from ashie/follow-up-#3405

out_forward: Use method local unpacker
fluent · Jun 3, 2021 · 8716489 · 8716489
2 parents 86c6a5e + 4aead7d
commit 8716489
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/lib/fluent/plugin/out_forward.rb b/lib/fluent/plugin/out_forward.rb
@@ -611,8 +611,7 @@ def establish_connection(sock, ri)
               sleep @sender.read_interval
               next
             end
-            unpacker = Fluent::MessagePackFactory.thread_local_msgpack_unpacker
-            unpacker.feed_each(buf) do |data|
+            Fluent::MessagePackFactory.msgpack_unpacker.feed_each(buf) do |data|
               if @handshake.invoke(sock, ri, data) == :established
                 @log.debug "connection established", host: @host, port: @port
               end