Skip to content

Commit

Permalink
Readding counts by category.
Browse files Browse the repository at this point in the history
Useful for finding out when to turn of b3 but also for figuring out the hdfs
issue

Author: @johanoskarsson
Fixes #77
URL: #77
  • Loading branch information
johanoskarsson committed Jul 19, 2012
1 parent b1c8dfa commit dd25b80
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -83,10 +83,12 @@ class ScribeCollectorService(config: ScribeZipkinCollectorConfig, val writeQueue

val scribeMessages = logEntries.flatMap {
entry =>
if (!categories.contains(entry.category.toLowerCase())) {
val category = entry.category.toLowerCase()
if (!categories.contains(category)) {
Stats.incr("collector.invalid_category")
None
} else {
Stats.incr("category." + category)
Some(entry.`message`)
}
}
Expand Down

0 comments on commit dd25b80

Please sign in to comment.