Adding classes to support asynchronous message consumption and aggregation