Ruby port of Apache Flume