Skip to content

Commit 4f6738e

Browse files
committed
fix slurped delete of adapter
1 parent 6d774c6 commit 4f6738e

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

hivemq-edge/src/main/java/com/hivemq/protocols/ProtocolAdapterManager.java

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,10 @@ public void refresh(final @NotNull List<ProtocolAdapterEntity> configs) {
228228
if (log.isDebugEnabled()) {
229229
log.debug("Deleting adapter '{}'", name);
230230
}
231-
stopAsync(name).whenComplete((ignored, t) -> deleteAdapterInternal(name)).get();
231+
stopAsync(name).handle((result, throwable) -> {
232+
deleteAdapterInternal(name);
233+
return null;
234+
}).get();
232235
} catch (final InterruptedException e) {
233236
Thread.currentThread().interrupt();
234237
failedAdapters.add(name);

0 commit comments

Comments
 (0)