Skip to content

Commit 6474fb6

Browse files
committed
Checkstyle
1 parent b33620b commit 6474fb6

File tree

2 files changed

+7
-3
lines changed

2 files changed

+7
-3
lines changed

api/src/main/java/io/kafbat/ui/service/app/ConfigReloadService.java

Lines changed: 1 addition & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -102,8 +102,7 @@ private void reloadFile(Path path) {
102102
Binder binder = Binder.get(environment);
103103

104104
binder.bind("rbac", RoleBasedAccessControlProperties.class)
105-
.ifBound(bound -> rbacProperties.setRoles(bound.getRoles())
106-
);
105+
.ifBound(bound -> rbacProperties.setRoles(bound.getRoles()));
107106
} catch (Throwable e) {
108107
log.error("Error while reloading file {}", path, e);
109108
}

api/src/main/java/io/kafbat/ui/util/MultiFileWatcher.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -39,7 +39,6 @@ public MultiFileWatcher(Collection<Path> filesToWatch, Consumer<Path> reloader)
3939
}
4040

4141

42-
var directories = filesToWatch.stream().map(Path::getParent).distinct().toList();
4342
watchedFiles.addAll(filesToWatch.stream()
4443
.map(p -> p.toAbsolutePath().normalize())
4544
.map(Path::toUri)
@@ -54,6 +53,12 @@ public MultiFileWatcher(Collection<Path> filesToWatch, Consumer<Path> reloader)
5453
log.debug("Going to watch {} files", watchedFiles.size());
5554
log.trace("Watching files: {}", watchedFiles.stream().map(URI::toString).toList());
5655

56+
var directories = filesToWatch
57+
.stream()
58+
.map(Path::getParent)
59+
.distinct()
60+
.toList();
61+
5762
directories
5863
.forEach(dir -> {
5964
try {

0 commit comments

Comments
 (0)