Kop 2694 xta client lib verwenden

src/test/java/de/ozgcloud/eingang/xta/XtaITCase.java

@@ -31,6 +31,8 @@ import java.lang.annotation.ElementType;
 import java.lang.annotation.Retention;
 import java.lang.annotation.RetentionPolicy;
 import java.lang.annotation.Target;
+import java.util.List;
+import java.util.function.Consumer;
 
 import lombok.SneakyThrows;
 import org.junit.jupiter.api.BeforeEach;
@@ -56,6 +58,7 @@ import de.ozgcloud.vorgang.grpc.binaryFile.BinaryFileServiceGrpc.BinaryFileServi
 import de.ozgcloud.vorgang.vorgang.GrpcEingang;
 import de.ozgcloud.vorgang.vorgang.VorgangServiceGrpc.VorgangServiceBlockingStub;
 import de.ozgcloud.xta.client.XtaClient;
+import de.ozgcloud.xta.client.model.XtaMessage;
 
 import io.grpc.Channel;
 import org.springframework.test.context.bean.override.mockito.MockitoBean;
@@ -81,7 +84,6 @@ class XtaITCase {
 	private ManagableStub<BinaryFileServiceStub> binaryFileManageableServiceStub;
 	@Mock
 	private BinaryFileServiceStub binaryFileServiceStub;
-
 	@Mock
 	private Channel channel;
 
@@ -90,7 +92,6 @@ class XtaITCase {
 
 	@Captor
 	private ArgumentCaptor<FormData> formDataArgumentCaptor;
-
 	@Captor
 	private ArgumentCaptor<GrpcEingang> eingangArgumentCaptor;
 
@@ -254,7 +255,13 @@ class XtaITCase {
 
 	@SneakyThrows
 	private void mockNachrichtenBroker(String zipFileName) {
-		// TODO
+		XtaMessage xtaMessage = XtaResponseTestFactory.createGetMessageResponse(zipFileName);
+		when(xtaClient.fetchMessages(any())).thenAnswer(invocation -> {
+			@SuppressWarnings("unchecked")
+			var processMessage = (Consumer<XtaMessage>) invocation.getArguments()[0];
+			processMessage.accept(xtaMessage);
+			return List.of(XtaTransportReportTestFactory.create());
+		});
 	}
 
 	@Target({ ElementType.METHOD })