diff --git a/src/main/java/de/ozgcloud/nachrichten/postfach/osiv2/transfer/PostfachApiFacadeService.java b/src/main/java/de/ozgcloud/nachrichten/postfach/osiv2/transfer/PostfachApiFacadeService.java index 7d3651aa1d42782ea1feaf76cbfdff25d09ff3dd..b2b14991c3dca01b23e9b8102149c8b4351ecc89 100644 --- a/src/main/java/de/ozgcloud/nachrichten/postfach/osiv2/transfer/PostfachApiFacadeService.java +++ b/src/main/java/de/ozgcloud/nachrichten/postfach/osiv2/transfer/PostfachApiFacadeService.java @@ -1,5 +1,7 @@ package de.ozgcloud.nachrichten.postfach.osiv2.transfer; +import java.util.Collection; +import java.util.Optional; import java.util.UUID; import java.util.stream.Stream; @@ -34,7 +36,10 @@ public class PostfachApiFacadeService { public Stream<PostfachNachricht> receiveMessages() { var response = messageExchangeApi.receiveMessages(MAX_NUMBER_RECEIVED_MESSAGES, 0); - return response.getMessages().stream().map(this::fetchMessageByGuid); + return Optional.ofNullable(response.getMessages()) + .stream() + .flatMap(Collection::stream) + .map(this::fetchMessageByGuid); } PostfachNachricht fetchMessageByGuid(final MessageExchangeReceiveMessage message) {