Kouhei Sutou
null+****@clear*****
Thu Apr 4 17:17:03 JST 2013
Kouhei Sutou 2013-04-04 17:17:03 +0900 (Thu, 04 Apr 2013) New Revision: 5bd87122c42e9ef2ca3c8c33bfaa4d6e8e181405 https://github.com/groonga/fluent-plugin-droonga/commit/5bd87122c42e9ef2ca3c8c33bfaa4d6e8e181405 Message: Use MessagePack as internal request format Because MessagePack is faster than JSON. Modified files: lib/droonga/worker.rb Modified: lib/droonga/worker.rb (+4 -7) =================================================================== --- lib/droonga/worker.rb 2013-04-04 17:03:46 +0900 (c620ab4) +++ lib/droonga/worker.rb 2013-04-04 17:17:03 +0900 (d3a7b18) @@ -18,13 +18,14 @@ require "groonga" require "droonga/handler_plugin" require "fluent-logger" -require "json" +require "msgpack" module Droonga class Worker def initialize(database, queue_name) @context = Groonga::Context.new @database =****@conte*****_database(database) + @context.encoding = :none @queue_name = queue_name @handlers = [] @outputs = {} @@ -63,9 +64,7 @@ module Droonga request = record.request if record end if request -# request.force_encoding("UTF-8") -# envelope = MessagePack.unpack(request) - envelope = JSON.parse(request) + envelope = MessagePack.unpack(request) process_message(envelope) if request end @status = :IDLE @@ -73,9 +72,7 @@ module Droonga end def post_message(envelope) -# request = envelope.to_msgpack -# request.force_encoding("UTF-8") - request = envelope.to_json + request = envelope.to_msgpack queue = @context[@queue_name] queue.push do |record| record.request = request -------------- next part -------------- HTML����������������������������...Download