Skip to content
Snippets Groups Projects
Commit 132e40e3 authored by Jörg Bolay's avatar Jörg Bolay
Browse files

OZG-4095 einführen MAX_NUMBER_RECEIVED_MESSAGES

parent b5ff0896
Branches
Tags
1 merge request!6OZG-4095 Testcase deleteMessage implementiert
Pipeline #1472 passed
......@@ -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);
}
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment