From 132e40e3e09fe85ddc9843c951516b18b9cd4f82 Mon Sep 17 00:00:00 2001
From: Joerg Bolay <joerg.bolay@dataport.de>
Date: Wed, 15 Jan 2025 16:02:25 +0100
Subject: [PATCH] =?UTF-8?q?OZG-4095=20einf=C3=BChren=20MAX=5FNUMBER=5FRECE?=
=?UTF-8?q?IVED=5FMESSAGES?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
---
.../osiv2/transfer/PostfachApiFacadeService.java | 10 ++++------
1 file changed, 4 insertions(+), 6 deletions(-)
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 13fa9e9..246a121 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);
}
--
GitLab