test XtaService::fetchMessages uses processMessage

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);
 	}
 

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