Navigation Menu

Skip to content

Commit

Permalink
Use more meaningful method name
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Jan 6, 2015
1 parent 6bd1683 commit 6ed6292
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions lib/droonga/forward_buffer.rb
Expand Up @@ -57,7 +57,7 @@ def add(message, destination)
def start_forward
logger.trace("start_forward: start")
Pathname.glob("#{@data_directory}/*#{SUFFIX}").collect do |buffered_message_path|
output(buffered_message_path)
forward(buffered_message_path)
end
logger.trace("start_forward: done")
end
Expand All @@ -67,17 +67,16 @@ def empty?
end

private
def output(buffered_message_path)
logger.trace("output: start (#{buffered_message_path})")
time_stamp = buffered_message_path.basename(SUFFIX)
def forward(buffered_message_path)
logger.trace("forward: start (#{buffered_message_path})")
file_contents = buffered_message_path.read
@unpacker.feed(file_contents)
buffered_message = @unpacker.read
@unpacker.reset
@forwarder.forward(buffered_message["message"],
buffered_message["destination"])
FileUtils.rm_f(buffered_message_path.to_s)
logger.trace("output: done (#{buffered_message_path})")
logger.trace("forward: done (#{buffered_message_path})")
end

def file_path(time_stamp=Time.now)
Expand Down

0 comments on commit 6ed6292

Please sign in to comment.