Current implementation of the FlowControllerContainer does not expose collectionProcessComplete(). Also, it appears that the ASB_impl never calls CPC on the flow controller. Three changes are needed:
1) Add collectionProcessComplete() method to the FlowControllerContainer 2) Add getFlowControllerContainer() method to ASB interface. The ASB_impl already supports this. 3) Modify collectionProcessComplete() method in AggregateAnalysisEngine_impl to fetch FlowControllerContainer and delegate collectionProcessComplete().