diff --git a/lib/droonga/command/droonga_engine_service.rb b/lib/droonga/command/droonga_engine_service.rb index 804f3007..b9a68829 100644 --- a/lib/droonga/command/droonga_engine_service.rb +++ b/lib/droonga/command/droonga_engine_service.rb @@ -129,6 +129,7 @@ def run_internal_message_receiver def create_internal_message_receiver InternalFluentMessageReceiver.new(@loop, host) do |tag, time, record| + logger.trace("InternalFluentMessageReceiver receive") on_message(tag, time, record) end end @@ -177,6 +178,7 @@ def create_receiver :heartbeat_fd => @heartbeat_fd, } FluentMessageReceiver.new(@loop, options) do |tag, time, record| + logger.trace("FluentMessageReceiver receive") on_message(tag, time, record) end end