Messages can be submitted to POST: <endpoint>/api/aggregators?type=<entity-type>&id=<entity-id>. These messages will be aggregated according to the corresponding entry in aggregator-config.yml. When the number of messages received equals completion-size, or the completion-timeout is reached after the last message is received, then the aggregated message will be submitted to <endpoint>/api/jobconfigs/<entity-id>/listener. The aggregated message can be accessed through djmessage 'msg1' within the dataconnect process.