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 13fa9e923020ab979f611e821a652237a79c173e..246a12108b9fdc919df2bd87b11aa93219f71d8a 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 @@ -14,11 +14,9 @@ import lombok.extern.log4j.Log4j2; @Log4j2 @Service @ConditionalOnProperty("ozgcloud.osiv2-postfach.enabled") -public record PostfachApiFacadeService( - MessageExchangeApi messageExchangeApi, - RequestMapper requestMapper, - ResponseMapper responseMapper -) { +public record PostfachApiFacadeService(MessageExchangeApi messageExchangeApi, RequestMapper requestMapper, ResponseMapper responseMapper) { + + private static int MAX_NUMBER_RECEIVED_MESSAGES = 100; public void sendMessage(PostfachNachricht nachricht) { messageExchangeApi.sendMessage( requestMapper.mapMailboxId(nachricht), @@ -27,7 +25,7 @@ public record PostfachApiFacadeService( } public Stream<PostfachNachricht> receiveMessages() { - var response = messageExchangeApi.receiveMessages(100, 0).block(); + var response = messageExchangeApi.receiveMessages(MAX_NUMBER_RECEIVED_MESSAGES, 0).block(); return response.getMessages().stream().map(this::fetchMessageByGuid); }