Skip to content

Commit

Permalink
Output more trace log to detect which FluentMessageReceiver
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 2, 2015
1 parent dcfd751 commit ecad462
Showing 1 changed file with 2 additions and 0 deletions.
2 changes: 2 additions & 0 deletions lib/droonga/command/droonga_engine_service.rb
Expand Up @@ -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
Expand Down Expand Up @@ -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
Expand Down

0 comments on commit ecad462

Please sign in to comment.