From 4629a2fae714ae7b0c118e4f23a6fe8c0fa2b29b Mon Sep 17 00:00:00 2001
From: Radek Davidek <rdavidek@trask.cz>
Date: Tue, 17 Mar 2026 20:05:00 +0100
Subject: [PATCH] fixed vault

---
 .../harness/connectors/messaging/IbmMqConnector.java   | 10 ++++++++++
 .../harness/endpoints/imq/ImqFirstVisionEndpoint.java  |  8 +++-----
 tests/src/test/resources/envs/mq                       |  2 +-
 3 files changed, 14 insertions(+), 6 deletions(-)

diff --git a/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java b/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java
index ca6684e..533d922 100644
--- a/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java
+++ b/test-harness/src/main/java/cz/moneta/test/harness/connectors/messaging/IbmMqConnector.java
@@ -184,6 +184,16 @@ public class IbmMqConnector implements Connector {
 		if (properties != null) {
 			for (Map.Entry<String, String> entry : properties.entrySet()) {
 				try {
+					if (entry.getKey().equals(ImqRequest.PROP_JMS_CORRELATION_ID)) {
+						message.setJMSCorrelationID(entry.getValue());
+						continue;
+					} else if (entry.getKey().equals(ImqRequest.PROP_JMS_TYPE)) {
+						message.setJMSType(entry.getValue());
+						continue;
+					} else if (entry.getKey().equals(ImqRequest.PROP_JMS_MESSAGE_ID)) {
+						message.setJMSMessageID(entry.getValue());
+						continue;
+					}
 					message.setStringProperty(entry.getKey(), entry.getValue());
 				} catch (JMSException e) {
 					LOG.warn("Failed to set property: {}", entry.getKey(), e);
diff --git a/test-harness/src/main/java/cz/moneta/test/harness/endpoints/imq/ImqFirstVisionEndpoint.java b/test-harness/src/main/java/cz/moneta/test/harness/endpoints/imq/ImqFirstVisionEndpoint.java
index 38f6172..3ebe10f 100644
--- a/test-harness/src/main/java/cz/moneta/test/harness/endpoints/imq/ImqFirstVisionEndpoint.java
+++ b/test-harness/src/main/java/cz/moneta/test/harness/endpoints/imq/ImqFirstVisionEndpoint.java
@@ -48,7 +48,7 @@ public class ImqFirstVisionEndpoint implements Endpoint {
 
         // Load credentials from Vault
         String vaultPath = getVaultPath();
-        //Credentials credentials = loadCredentialsFromVault(vaultPath);
+        Credentials credentials = loadCredentialsFromVault(vaultPath);
 
         // SSL configuration (optional)
         String keystorePath = "/home/kamma/aa/mq-docker/truststore.jks";
@@ -59,10 +59,8 @@ public class ImqFirstVisionEndpoint implements Endpoint {
                     connectionNameList,
                     channel,
                     queueManager,
-                    //credentials.getUsername(),
-                    //credentials.getPassword(),
-                    "app",
-					"app",
+                    credentials.getUsername(),
+                    credentials.getPassword(),
                     keystorePath,
                     keystorePassword,
                     sslCipherSuite
diff --git a/tests/src/test/resources/envs/mq b/tests/src/test/resources/envs/mq
index 7f6ed5e..ab1f0ee 100644
--- a/tests/src/test/resources/envs/mq
+++ b/tests/src/test/resources/envs/mq
@@ -20,7 +20,7 @@ endpoints.imq-first-vision.mf-utf8.queue=UTF8.QUEUE.1
 
 
 vault.url=http://localhost:8200
-vault.username=app
+vault.user=app
 vault.password=app
 
 #Vault path for IBM MQ credentials