Skip to content

Commit ca5d8be

Browse files
committed
feat: make NeonBee boot logging a little more verbose
1 parent 9d01198 commit ca5d8be

File tree

1 file changed

+17
-4
lines changed

1 file changed

+17
-4
lines changed

src/main/java/io/neonbee/NeonBee.java

Lines changed: 17 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -288,6 +288,7 @@ static Future<Vertx> newVertx(VertxOptions vertxOptions, NeonBeeOptions options)
288288
}
289289

290290
private Future<Void> boot() {
291+
logger.info("Booting NeonBee ...");
291292
return registerHooks().compose(nothing -> hookRegistry.executeHooks(HookType.BEFORE_BOOTSTRAP))
292293
.onSuccess(anything -> {
293294
// set the default timezone and overwrite any configured user.timezone property
@@ -296,7 +297,8 @@ private Future<Void> boot() {
296297
// further synchronous initializations which should happen before verticles are getting deployed
297298
}).compose(nothing -> all(initializeSharedMaps(), decorateEventBus(), createMicrometerRegistries()))
298299
.compose(nothing -> all(deployVerticles(), deployModules())) // deployment of verticles & modules
299-
.compose(nothing -> hookRegistry.executeHooks(HookType.AFTER_STARTUP)).mapEmpty();
300+
.compose(nothing -> hookRegistry.executeHooks(HookType.AFTER_STARTUP))
301+
.onSuccess(result -> logger.info("Successfully booted NeonBee!")).mapEmpty();
300302
}
301303

302304
private Future<Void> registerHooks() {
@@ -397,8 +399,12 @@ Future<Void> createMicrometerRegistries() {
397399
private Future<Void> deployVerticles() {
398400
Collection<NeonBeeProfile> activeProfiles = options.getActiveProfiles();
399401
if (logger.isInfoEnabled()) {
400-
logger.info("Deploying verticle with active profiles: {}",
401-
activeProfiles.stream().map(NeonBeeProfile::name).collect(Collectors.joining(",")));
402+
if (!activeProfiles.isEmpty()) {
403+
logger.info("Deploying verticle with active profiles: {}", // NOPMD log guard false positive
404+
activeProfiles.stream().map(NeonBeeProfile::name).collect(Collectors.joining(", ")));
405+
} else {
406+
logger.info("No active profiles, only deploying system verticles");
407+
}
402408
}
403409

404410
List<Future<?>> deployFutures = new ArrayList<>();
@@ -531,7 +537,14 @@ private Future<Void> deployModules() {
531537

532538
@VisibleForTesting
533539
Future<NeonBeeConfig> loadConfig() {
534-
return NeonBeeConfig.load(vertx).onSuccess(config -> this.config = config);
540+
logger.info("Loading NeonBee configuration ...");
541+
return NeonBeeConfig.load(vertx).onSuccess(config -> {
542+
this.config = config;
543+
logger.info("Successfully loaded NeonBee configuration");
544+
if (logger.isDebugEnabled()) {
545+
logger.debug("Loaded configuration {}", config);
546+
}
547+
}).onFailure(throwable -> logger.error("Failed to load NeonBee configuration", throwable));
535548
}
536549

537550
@SuppressWarnings("rawtypes")

0 commit comments

Comments
 (0)