OZG-6753 KOP-2725 Test, dass Nachricht geschlossen wird, an Nachrichtenbroker Verhalten anpassen

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")

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