Expand processing framework to support reliable message that are
guaranteed to be process at least once. Implement service to control
aggregate address processing.