Skip to content

Commit 8e3e6d0

Browse files
control plane > fix bootstrap
1 parent b62087f commit 8e3e6d0

File tree

2 files changed

+4
-3
lines changed

2 files changed

+4
-3
lines changed

hivemq-edge/src/main/java/com/hivemq/HiveMQEdgeMain.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -158,7 +158,7 @@ private void afterHiveMQStartBootstrap() {
158158
injector.services().modulesAndExtensionsService());
159159
injector.commercialModuleLoaderDiscovery().afterHiveMQStart(afterHiveMQStartBootstrapService);
160160
} catch (Exception e) {
161-
log.warn("Error on bootstraping persistences.", e);
161+
log.warn("Error on bootstrapping modules:", e);
162162
throw new HiveMQEdgeStartupException(e);
163163
}
164164
}

hivemq-edge/src/main/java/com/hivemq/extensions/core/CommercialModuleLoaderDiscovery.java

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -16,6 +16,7 @@
1616
package com.hivemq.extensions.core;
1717

1818
import com.google.common.collect.ImmutableList;
19+
import com.hivemq.bootstrap.services.AfterHiveMQStartBootstrapService;
1920
import com.hivemq.bootstrap.services.CompleteBootstrapService;
2021
import com.hivemq.bootstrap.services.GeneralBootstrapService;
2122
import com.hivemq.bootstrap.services.PersistenceBootstrapService;
@@ -72,10 +73,10 @@ public void completeBootstrap(final @NotNull CompleteBootstrapService completeBo
7273
}
7374

7475

75-
public void afterHiveMQStart(final @NotNull CompleteBootstrapService completeBootstrapService) {
76+
public void afterHiveMQStart(final @NotNull AfterHiveMQStartBootstrapService afterHiveMQStartBootstrapService) {
7677
try {
7778
for (ModuleLoaderMain instance : instances) {
78-
instance.afterPersistenceBootstrap(completeBootstrapService);
79+
instance.afterHiveMQStart(afterHiveMQStartBootstrapService);
7980
}
8081
} catch (Exception e) {
8182
log.error("Error when completing bootstrap ", e);

0 commit comments

Comments
 (0)