From 45f592cdede89f3cf2f2f70eeb2394043c17fb42 Mon Sep 17 00:00:00 2001
From: Jan Zickermann <jan.zickermann@dataport.de>
Date: Thu, 25 Jul 2024 13:01:18 +0200
Subject: [PATCH] KOP-2139 KOP-2467 XtaClientITCase: Create extension for dev
server setup
---
.../ozgcloud/xta/client/XtaClientITCase.java | 5 ++--
.../client/XtaDevServerSetupExtension.java | 27 +++++++++++--------
2 files changed, 18 insertions(+), 14 deletions(-)
diff --git a/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java b/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
index 646c79f..2682f85 100644
--- a/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
+++ b/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
@@ -43,7 +43,7 @@ class XtaClientITCase {
@DisplayName("should return zero pending messages")
@ParameterizedTest
- @ValueSource(strings = { CLIENT_IDENTIFIER1, CLIENT_IDENTIFIER2})
+ @ValueSource(strings = { CLIENT_IDENTIFIER1, CLIENT_IDENTIFIER2 })
@SneakyThrows
void shouldReturnZeroPendingMessages(String clientIdentifiers) {
var result = client.getMessagesMetadata(clientIdentifiers);
@@ -68,6 +68,7 @@ class XtaClientITCase {
var result = client.getMessagesMetadata(CLIENT_IDENTIFIER2);
assertThat(result.pendingMessageCount()).isOne();
+
}
@DisplayName("should return no pending message for client1")
@@ -82,7 +83,5 @@ class XtaClientITCase {
}
-
-
}
diff --git a/src/test/java/de/ozgcloud/xta/client/XtaDevServerSetupExtension.java b/src/test/java/de/ozgcloud/xta/client/XtaDevServerSetupExtension.java
index 5d52441..6eeca9b 100644
--- a/src/test/java/de/ozgcloud/xta/client/XtaDevServerSetupExtension.java
+++ b/src/test/java/de/ozgcloud/xta/client/XtaDevServerSetupExtension.java
@@ -16,12 +16,15 @@ import de.ozgcloud.xta.client.model.Identifier;
import de.ozgcloud.xta.client.model.XtaMessageMetaData;
import de.ozgcloud.xta.client.model.XtaMessageMetaDataTestFactory;
import de.ozgcloud.xta.client.model.XtaMessageTestFactory;
+import genv3.de.xoev.transport.xta.x211.ParameterIsNotValidException;
import lombok.Getter;
import lombok.Setter;
import lombok.SneakyThrows;
+import lombok.extern.slf4j.Slf4j;
@Getter
@Setter
+@Slf4j
public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEachCallback {
private XtaClient client;
@@ -81,15 +84,19 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
@SneakyThrows
void sendTestMessageToClient2(Identifier author, Identifier reader) {
var messageId = service.createMessageId(author);
-
- service.sendMessage(XtaMessageTestFactory.createBuilder()
- .metaData(XtaMessageMetaDataTestFactory.createBuilder()
- .authorIdentifier(author)
- .readerIdentifier(reader)
- .messageId(messageId)
- .build())
- .build()
- );
+ try {
+ service.sendMessage(XtaMessageTestFactory.createBuilder()
+ .metaData(XtaMessageMetaDataTestFactory.createBuilder()
+ .authorIdentifier(author)
+ .readerIdentifier(reader)
+ .messageId(messageId)
+ .build())
+ .build()
+ );
+ } catch (ParameterIsNotValidException e) {
+ log.error("Failed to send test message to client2: {}", e.getFaultInfo().getErrorCode().getName());
+ throw e;
+ }
}
@SneakyThrows
@@ -103,7 +110,6 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
}
}
-
@SneakyThrows
private static byte[] readBytesFromFile(String path) {
return Files.toByteArray(new File(path));
@@ -117,5 +123,4 @@ public class XtaDevServerSetupExtension implements BeforeAllCallback, BeforeEach
return client.deriveIdentifier(CLIENT_IDENTIFIER2);
}
-
}
--
GitLab