lgtm. Only thing - can we add a unit test for this functionality?
Thanks for the review, Mike.
Ganglia uses a binary protocol as you can see to transmit the data. I could not find a Ganglia server unit test framework, the only way we could add one is to consider the same protocol used to send. For now, I filed: https://issues.apache.org/jira/browse/FLUME-1375 to track this. If I can find a way to add these tests, will add it later if you don't mind.