Navigation Menu

Skip to content

Commit

Permalink
Extract buffered message envelope correctly
Browse files Browse the repository at this point in the history
  • Loading branch information
piroor committed Apr 8, 2015
1 parent 3e14d7e commit 5eda93c
Showing 1 changed file with 1 addition and 0 deletions.
1 change: 1 addition & 0 deletions lib/droonga/forward_buffer.rb
Expand Up @@ -88,6 +88,7 @@ def forward(buffered_message_path)
@unpacker.reset

if @process_messages_newer_than_timestamp
message = buffered_message["message"]
message_timestamp = Time.parse(message["date"])
logger.trace("Checking boundary of obsolete message",
:newer_than => @process_messages_newer_than_timestamp,
Expand Down

0 comments on commit 5eda93c

Please sign in to comment.