Skip to content

Commit e5ce7fa

Browse files
committed
Do not increment MIN
Update device lib
1 parent 91c8664 commit e5ce7fa

File tree

1 file changed

+6
-1
lines changed

1 file changed

+6
-1
lines changed

src/main/java/io/mapsmessaging/engine/destination/DestinationManagerPipeline.java

Lines changed: 6 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -152,7 +152,12 @@ public CompletableFuture<Boolean> stop() {
152152
public CompletableFuture<Map<String, DestinationImpl>> copy(DestinationFilter filter, Map<String, DestinationImpl> response) {
153153
CompletableFuture<Map<String, DestinationImpl>> future = new CompletableFuture<>();
154154
Callable<Void> task = () -> {
155-
future.complete(copyInternal(filter, response));
155+
try {
156+
future.complete(copyInternal(filter, response));
157+
} catch (Exception e) {
158+
// todo log this
159+
future.completeExceptionally(e);
160+
}
156161
return null;
157162
};
158163
taskScheduler.submit(task);

0 commit comments

Comments
 (0)