Kouhei Sutou
null+****@clear*****
Mon Dec 16 15:19:12 JST 2013
Kouhei Sutou 2013-12-16 15:19:12 +0900 (Mon, 16 Dec 2013) New Revision: 62d3d48e99a72037125db6208d875d1f50d0d165 https://github.com/droonga/fluent-plugin-droonga/commit/62d3d48e99a72037125db6208d875d1f50d0d165 Message: Use correct name A fluent message is [tag, time, data] not [tag, time, data].to_msgpack. Modified files: lib/droonga/fluent_message_sender.rb Modified: lib/droonga/fluent_message_sender.rb (+3 -4) =================================================================== --- lib/droonga/fluent_message_sender.rb 2013-12-16 15:17:02 +0900 (27a4f76) +++ lib/droonga/fluent_message_sender.rb 2013-12-16 15:19:12 +0900 (6ffebaf) @@ -41,10 +41,9 @@ module Droonga def send(tag, data) $log.trace("#{log_tag}: send: start") connect if****@socke*****? - fluent_message = MessagePackPacker.pack( - [tag, Time.now.to_i, data] - ) - @socket.write(fluent_message) + fluent_message = [tag, Time.now.to_i, data] + packed_fluent_message = MessagePackPacker.pack(fluent_message) + @socket.write(packed_fluent_message) @loop.break_current_loop $log.trace("#{log_tag}: send: done") end -------------- next part -------------- HTML����������������������������...Download
