Moved the class from Flume to ActiveMQ