Skip to content

Commit 20d6357

Browse files
committed
Add error handling to DefaultChannelsService
1 parent ff9ebc9 commit 20d6357

File tree

1 file changed

+10
-4
lines changed

1 file changed

+10
-4
lines changed

springwolf-core/src/main/java/io/github/stavshamir/springwolf/asyncapi/DefaultChannelsService.java

Lines changed: 10 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -8,6 +8,7 @@
88

99
import javax.annotation.PostConstruct;
1010
import java.util.Collection;
11+
import java.util.Collections;
1112
import java.util.Map;
1213
import java.util.Set;
1314

@@ -23,10 +24,15 @@ public class DefaultChannelsService implements ChannelsService {
2324

2425
@PostConstruct
2526
void findChannels() {
26-
channels = channelsScanners.stream()
27-
.map(ChannelsScanner::scan)
28-
.map(Map::entrySet).flatMap(Collection::stream)
29-
.collect(toMap(Map.Entry::getKey, Map.Entry::getValue));
27+
try {
28+
channels = channelsScanners.stream()
29+
.map(ChannelsScanner::scan)
30+
.map(Map::entrySet).flatMap(Collection::stream)
31+
.collect(toMap(Map.Entry::getKey, Map.Entry::getValue));
32+
} catch (Exception e) {
33+
log.error("An error was encountered during channel scanning: {}", e.getMessage());
34+
channels = Collections.emptyMap();
35+
}
3036
}
3137

3238
@Override

0 commit comments

Comments
 (0)