You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by lb...@apache.org on 2021/02/03 20:11:26 UTC
[camel] 02/02: camel-main: improve DefaultRoutesCollector
This is an automated email from the ASF dual-hosted git repository.
lburgazzoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/camel.git
commit b44789aca7ab4a573be72f03a9a34f68a7ac8aa0
Author: Luca Burgazzoli <lb...@gmail.com>
AuthorDate: Wed Feb 3 17:19:26 2021 +0100
camel-main: improve DefaultRoutesCollector
---
.../java/org/apache/camel/main/DefaultRoutesCollector.java | 11 ++++++++---
1 file changed, 8 insertions(+), 3 deletions(-)
diff --git a/core/camel-main/src/main/java/org/apache/camel/main/DefaultRoutesCollector.java b/core/camel-main/src/main/java/org/apache/camel/main/DefaultRoutesCollector.java
index 9988149..198697f 100644
--- a/core/camel-main/src/main/java/org/apache/camel/main/DefaultRoutesCollector.java
+++ b/core/camel-main/src/main/java/org/apache/camel/main/DefaultRoutesCollector.java
@@ -141,11 +141,16 @@ public class DefaultRoutesCollector implements RoutesCollector {
continue;
}
- log.debug("Found route builder from location: {}", include);
- ecc.getRoutesLoader().findRoutesBuilders(resource).forEach(builder -> {
+ Collection<RoutesBuilder> builders = ecc.getRoutesLoader().findRoutesBuilders(resource);
+ if (builders.isEmpty()) {
+ continue;
+ }
+
+ log.debug("Found {} route builder from location: {}", builders.size(), include);
+ for (RoutesBuilder builder : builders) {
answer.add(builder);
count.incrementAndGet();
- });
+ }
}
} catch (FileNotFoundException e) {
log.debug("No RoutesBuilder found in {}. Skipping detection.", include);