diff --git a/src/main/java/de/ozgcloud/eingang/xta/XtaService.java b/src/main/java/de/ozgcloud/eingang/xta/XtaService.java
index b395e0286f4535218ea3a1a67f655c8f214cd5d3..e1308d3934da198b27f8089ce612db5fb485f0c8 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 7e9bbf9ff1ff38f6d9f6c89f1af62cee88990e7f..7690d8be39eed9638b292df932802d1cabccab9d 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