OZG-6240 KOP-2586 Add getMessage ITCase test

src/test/java/de/ozgcloud/xta/client/XtaClientITCase.java

@@ -9,6 +9,7 @@ import org.junit.jupiter.api.Nested;
 import org.junit.jupiter.api.Test;
 import org.junit.jupiter.api.extension.RegisterExtension;
 
+import genv3.de.xoev.transport.xta.x211.InvalidMessageIDException;
 import lombok.SneakyThrows;
 
 class XtaClientITCase {
@@ -68,8 +69,48 @@ class XtaClientITCase {
 
 				assertThat(result.pendingMessageCount()).isZero();
 			}
+
+		}
+
+	}
+
+	@DisplayName("get message")
+	@Nested
+	class TestGetMessage {
+
+		private String messageId;
+
+		@BeforeEach
+		@SneakyThrows
+		void setup() {
+			messageId = XTA_TEST_SERVER_SETUP_EXTENSION.sendTestMessage();
+		}
+
+		@DisplayName("should return message")
+		@Test
+		@SneakyThrows
+		void shouldReturnMessage() {
+			var result = client.getMessage(CLIENT_IDENTIFIER1.value(), messageId);
+
+			assertThat(result.metaData().messageId()).isEqualTo(messageId);
+		}
+
+		@DisplayName("should throw invalid message id exception for modified message id")
+		@Test
+		void shouldThrowInvalidMessageIdExceptionForModifiedMessageId() {
+			assertThatThrownBy(() -> client.getMessage(CLIENT_IDENTIFIER1.value(), messageId + "1"))
+					.isInstanceOf(InvalidMessageIDException.class);
+		}
+
+
+		@DisplayName("should throw invalid message id exception for other client")
+		@Test
+		void shouldThrowInvalidMessageIdExceptionForOtherClient() {
+			assertThatThrownBy(() -> client.getMessage(CLIENT_IDENTIFIER2.value(), messageId))
+					.isInstanceOf(InvalidMessageIDException.class);
 		}
 
+
 	}
 
 }

src/test/java/de/ozgcloud/xta/client/XtaTestServerSetupExtension.java

@@ -108,12 +108,12 @@ public class XtaTestServerSetupExtension implements BeforeAllCallback, AfterAllC
 	}
 
 	@SneakyThrows
-	public void sendTestMessage() {
-		sendTestMessage(CLIENT_IDENTIFIER1, CLIENT_IDENTIFIER1);
+	public String sendTestMessage() {
+		return sendTestMessage(CLIENT_IDENTIFIER1, CLIENT_IDENTIFIER1);
 	}
 
 	@SneakyThrows
-	void sendTestMessage(Identifier author, Identifier reader) {
+	String sendTestMessage(Identifier author, Identifier reader) {
 		var messageId = service.createMessageId(author);
 		var message = XtaMessageExampleLoader.load(
 				XtaMessageExampleLoader.MessageExampleConfig.builder()
@@ -141,6 +141,7 @@ public class XtaTestServerSetupExtension implements BeforeAllCallback, AfterAllC
 			logCodeFehlerNummer(e.getFaultInfo().getErrorCode());
 			throw e;
 		}
+		return messageId;
 	}
 
 	private void logCodeFehlerNummer(CodeFehlernummer fehlernummer) {