Browse files

Emit message with filtered tags.

  • Loading branch information...
1 parent 70213dd commit 49bf052b9aeeb060fe4e5de993b24219b85338d6 @kentaro committed Jul 4, 2012
Showing with 3 additions and 3 deletions.
  1. +1 −1 fluent-plugin-rewrite.gemspec
  2. +2 −2 lib/fluent/plugin/out_rewrite.rb
View
2 fluent-plugin-rewrite.gemspec
@@ -1,6 +1,6 @@
Gem::Specification.new do |gem|
gem.name = "fluent-plugin-rewrite"
- gem.version = '0.0.7'
+ gem.version = '0.0.8'
gem.authors = ["Kentaro Kuribayashi"]
gem.email = ["kentarok@gmail.com"]
gem.homepage = "http://github.com/kentaro/fluent-plugin-rewrite"
View
4 lib/fluent/plugin/out_rewrite.rb
@@ -51,8 +51,8 @@ def emit(tag, es, chain)
end
es.each do |time, record|
- tag, record = rewrite(tag, record)
- Engine.emit(tag, time, record) if tag && record
+ filtered_tag, record = rewrite(tag, record)
+ Engine.emit(filtered_tag, time, record) if filtered_tag && record
end
chain.next

0 comments on commit 49bf052

Please sign in to comment.