concurrent-aggregator

@EnableConcurrentAggregate("com.digibig.service.im.aggregator")

@ConcurrentAggregate
public interface DemoAggregateProxy {
    @AggregateProviders({
            @AggregateProvider(beanClass = StudentService.class, method = "getStudentById", parameters = @AggregateParameter(name = "ids")),
            @AggregateProvider(beanClass = TeacherService.class, method = "getTeacherByStudentId", parameters = @AggregateParameter(name = "ids"))})
    @AggregateConsumer(beanClass = StudentTeacherAggregator.class,method = "studentWithTeachers")
    List<Student> demoStudent(@AggregateParameterName("ids") List<Integer> ids);
}

    @Autowired
    @SuppressWarnings("all")
    private DemoAggregateProxy demoAggregateProxy;