Changed the simple consumer to a pull-parser, though need to add chunking
Generified chunking logic into AsyncChuncker and use in simple subscription
Moved duplicated subscription setup code to abstract class
Moved log parsing code to more appropriate class