test/plugin/test_out_copy.rb in fluentd-0.12.16 vs test/plugin/test_out_copy.rb in fluentd-0.12.17
- old
+ new
@@ -84,10 +84,10 @@
d.instance.instance_eval { @outputs = outputs }
es = if defined?(MessagePack::Packer)
time = Time.parse("2013-05-26 06:37:22 UTC").to_i
- packer = MessagePack::Packer.new
+ packer = Fluent::Engine.msgpack_factory.packer
packer.pack([time, {"a" => 1}])
packer.pack([time, {"a" => 2}])
Fluent::MessagePackEventStream.new(packer.to_s)
else
events = "#{[time, {"a" => 1}].to_msgpack}#{[time, {"a" => 2}].to_msgpack}"