in flume-spring-boot/src/main/java/org/apache/flume/spring/boot/config/SpringConfiguration.java [46:58]
public MaterializedConfiguration configuration() {
MaterializedConfiguration config = new SimpleMaterializedConfiguration();
for (Map.Entry<String, Channel> entry : channels.entrySet()) {
config.addChannel(entry.getKey(), entry.getValue());
}
for (Map.Entry<String, SinkRunner> entry : sinkRunners.entrySet()) {
config.addSinkRunner(entry.getKey(), entry.getValue());
}
for (Map.Entry<String, SourceRunner> entry : sourceRunners.entrySet()) {
config.addSourceRunner(entry.getKey(), entry.getValue());
}
return config;
}