renamed consumer.start to .init, firing "msg" event with raw messsage