From 0b17580b57a1126c9c01b9cff8e0c8cad0cc6de5 Mon Sep 17 00:00:00 2001
From: Lukas Malte Monnerjahn <lukasmalte.monnerjahn@dataport.de>
Date: Mon, 7 Oct 2024 12:29:14 +0200
Subject: [PATCH] OZG-6753 KOP-2725 Test, dass Nachricht geschlossen wird, an
Nachrichtenbroker Verhalten anpassen
---
.../ozgcloud/xta/client/XtaClientITCase.java | 11 +++++++----
.../xta/client/XtaClientRemoteITCase.java | 18 ++++++++++++++----
2 files changed, 21 insertions(+), 8 deletions(-)
diff --git a/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java b/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
index 53a9aee..cf0c0bc 100644
--- a/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
+++ b/src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java
@@ -121,12 +121,15 @@ class XtaClientITCase {
assertThat(messageContent).isEqualTo(resultContent);
}
- @DisplayName("should throw invalid message id exception for a closed message")
+ @DisplayName("should not show message id for a closed message in status list")
@Test
- void shouldThrowInvalidMessageIdExceptionForClosedMessage() {
+ @SneakyThrows
+ void shouldNotShowMessageIdForClosedMessageInStatusList() {
assertThatNoException().isThrownBy(() -> client.getMessage(READER_CLIENT_IDENTIFIER1.value(), messageId));
- assertThatThrownBy(() -> client.getMessage(READER_CLIENT_IDENTIFIER1.value(), messageId))
- .isInstanceOf(InvalidMessageIDException.class);
+ var metadataResult = client.getMessagesMetadata(READER_CLIENT_IDENTIFIER1.value());
+ if (!metadataResult.messages().isEmpty()) {
+ assertThat(metadataResult.messages()).allMatch(metadata -> !messageId.equals(metadata.messageId()));
+ }
}
@DisplayName("should throw invalid message id exception for modified message id")
diff --git a/src/test/java/de/ozgcloud/xta/client/XtaClientRemoteITCase.java b/src/test/java/de/ozgcloud/xta/client/XtaClientRemoteITCase.java
index 7c02352..ed36f8c 100644
--- a/src/test/java/de/ozgcloud/xta/client/XtaClientRemoteITCase.java
+++ b/src/test/java/de/ozgcloud/xta/client/XtaClientRemoteITCase.java
@@ -3,6 +3,7 @@ package de.ozgcloud.xta.client;
import static de.ozgcloud.xta.client.extension.XtaServerSetupExtensionTestUtil.*;
import static org.assertj.core.api.Assertions.*;
+import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.DisplayName;
import org.junit.jupiter.api.Nested;
@@ -136,12 +137,15 @@ class XtaClientRemoteITCase {
assertThat(messageContent).isEqualTo(resultContent);
}
- @DisplayName("should throw invalid message id exception for a closed message")
+ @DisplayName("should not show message id for a closed message in status list")
@Test
- void shouldThrowInvalidMessageIdExceptionForClosedMessage() {
+ @SneakyThrows
+ void shouldNotShowMessageIdForClosedMessageInStatusList() {
assertThatNoException().isThrownBy(() -> readerClient.getMessage(READER_CLIENT_IDENTIFIER1.value(), messageId));
- assertThatThrownBy(() -> readerClient.getMessage(READER_CLIENT_IDENTIFIER1.value(), messageId))
- .isInstanceOf(InvalidMessageIDException.class);
+ var metadataResult = readerClient.getMessagesMetadata(READER_CLIENT_IDENTIFIER1.value());
+ if (!metadataResult.messages().isEmpty()) {
+ assertThat(metadataResult.messages()).allMatch(metadata -> !messageId.equals(metadata.messageId()));
+ }
}
@DisplayName("should throw invalid message id exception for modified message id")
@@ -164,6 +168,12 @@ class XtaClientRemoteITCase {
@Nested
class TestSendMessage {
+ @AfterEach
+ @SneakyThrows
+ void afterEach() {
+ closeAllMessages(readerClient, READER_CLIENT_IDENTIFIER1);
+ }
+
@DisplayName("should return transport report with open status")
@SneakyThrows
@ParameterizedTest
--
GitLab