Skip to content

Commit f29c946

Browse files
committed
add missing completion for future on adapter start
1 parent 89736a6 commit f29c946

File tree

1 file changed

+6
-0
lines changed

1 file changed

+6
-0
lines changed

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

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -234,9 +234,15 @@ private void stopAfterFailedStart() {
234234
log.error("Failed to start writing for adapter with id {}.", adapter.getId(), e);
235235
future.completeExceptionally(e);
236236
}
237+
} else {
238+
future.complete(true);
237239
}
240+
} else {
241+
future.complete(true);
238242
}
239243
});
244+
} else {
245+
future.complete(true);
240246
}
241247
} catch (final Throwable e) {
242248
log.error("Protocol adapter start failed");

0 commit comments

Comments
 (0)