change package name, convert to AMQP, make Hadoop 1.x compatible