fixed vault
This commit is contained in:
parent
26b6354875
commit
4629a2fae7
@ -184,6 +184,16 @@ public class IbmMqConnector implements Connector {
|
|||||||
if (properties != null) {
|
if (properties != null) {
|
||||||
for (Map.Entry<String, String> entry : properties.entrySet()) {
|
for (Map.Entry<String, String> entry : properties.entrySet()) {
|
||||||
try {
|
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());
|
message.setStringProperty(entry.getKey(), entry.getValue());
|
||||||
} catch (JMSException e) {
|
} catch (JMSException e) {
|
||||||
LOG.warn("Failed to set property: {}", entry.getKey(), e);
|
LOG.warn("Failed to set property: {}", entry.getKey(), e);
|
||||||
|
|||||||
@ -48,7 +48,7 @@ public class ImqFirstVisionEndpoint implements Endpoint {
|
|||||||
|
|
||||||
// Load credentials from Vault
|
// Load credentials from Vault
|
||||||
String vaultPath = getVaultPath();
|
String vaultPath = getVaultPath();
|
||||||
//Credentials credentials = loadCredentialsFromVault(vaultPath);
|
Credentials credentials = loadCredentialsFromVault(vaultPath);
|
||||||
|
|
||||||
// SSL configuration (optional)
|
// SSL configuration (optional)
|
||||||
String keystorePath = "/home/kamma/aa/mq-docker/truststore.jks";
|
String keystorePath = "/home/kamma/aa/mq-docker/truststore.jks";
|
||||||
@ -59,10 +59,8 @@ public class ImqFirstVisionEndpoint implements Endpoint {
|
|||||||
connectionNameList,
|
connectionNameList,
|
||||||
channel,
|
channel,
|
||||||
queueManager,
|
queueManager,
|
||||||
//credentials.getUsername(),
|
credentials.getUsername(),
|
||||||
//credentials.getPassword(),
|
credentials.getPassword(),
|
||||||
"app",
|
|
||||||
"app",
|
|
||||||
keystorePath,
|
keystorePath,
|
||||||
keystorePassword,
|
keystorePassword,
|
||||||
sslCipherSuite
|
sslCipherSuite
|
||||||
|
|||||||
@ -20,7 +20,7 @@ endpoints.imq-first-vision.mf-utf8.queue=UTF8.QUEUE.1
|
|||||||
|
|
||||||
|
|
||||||
vault.url=http://localhost:8200
|
vault.url=http://localhost:8200
|
||||||
vault.username=app
|
vault.user=app
|
||||||
vault.password=app
|
vault.password=app
|
||||||
|
|
||||||
#Vault path for IBM MQ credentials
|
#Vault path for IBM MQ credentials
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user