From 2a509fecac9ad966cf6e9f5625429d72e170302c Mon Sep 17 00:00:00 2001
From: Lukas Malte Monnerjahn <lukasmalte.monnerjahn@dataport.de>
Date: Tue, 11 Mar 2025 17:42:06 +0100
Subject: [PATCH] test XtaService::fetchMessages uses processMessage
---
src/main/java/de/ozgcloud/eingang/xta/XtaService.java | 6 +++++-
src/test/java/de/ozgcloud/eingang/xta/XtaServiceTest.java | 4 ++--
2 files changed, 7 insertions(+), 3 deletions(-)
diff --git a/src/main/java/de/ozgcloud/eingang/xta/XtaService.java b/src/main/java/de/ozgcloud/eingang/xta/XtaService.java
index b395e028..e1308d39 100644
--- a/src/main/java/de/ozgcloud/eingang/xta/XtaService.java
+++ b/src/main/java/de/ozgcloud/eingang/xta/XtaService.java
@@ -27,6 +27,7 @@ import java.util.Collection;
import java.util.Collections;
import java.util.List;
import java.util.Optional;
+import java.util.function.Consumer;
import lombok.NonNull;
import lombok.SneakyThrows;
@@ -59,6 +60,8 @@ class XtaService {
static final String FIM_MESSAGE_TYPE_PREFIX = "fim.";
+ final Consumer<XtaMessage> MESSAGE_PROCESSOR = this::processMessage;
+
@Autowired
private XtaClient xtaClient;
@Autowired
@@ -76,7 +79,8 @@ class XtaService {
@SneakyThrows
public void fetchMessages() {
- var transportReports = xtaClient.fetchMessages(this::processMessage);
+
+ var transportReports = xtaClient.fetchMessages(MESSAGE_PROCESSOR);
logTransportReports(transportReports);
}
diff --git a/src/test/java/de/ozgcloud/eingang/xta/XtaServiceTest.java b/src/test/java/de/ozgcloud/eingang/xta/XtaServiceTest.java
index 7e9bbf9f..7690d8be 100644
--- a/src/test/java/de/ozgcloud/eingang/xta/XtaServiceTest.java
+++ b/src/test/java/de/ozgcloud/eingang/xta/XtaServiceTest.java
@@ -94,10 +94,10 @@ class XtaServiceTest {
@Test
@SneakyThrows
- void shouldCallXtaClient() {
+ void shouldUseMessageProcessor() {
service.fetchMessages();
- verify(xtaClient).fetchMessages(any());
+ verify(xtaClient).fetchMessages(service.MESSAGE_PROCESSOR);
}
@Test
--
GitLab