Refactored AkkaConsumer internals.