This is an automated email from the ASF dual-hosted git repository.
gtully pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/activemq-artemis.git
The following commit(s) were added to refs/heads/main by this push:
new dc7d1e25cc NO-JIRA - add test for ENC of tls params for broker amqp
connection via props
dc7d1e25cc is described below
commit dc7d1e25cc40015591a42f5e981eb891928dba6d
Author: Gary Tully <[email protected]>
AuthorDate: Thu Mar 2 12:53:30 2023 +0000
NO-JIRA - add test for ENC of tls params for broker amqp connection via
props
---
.../artemis/core/config/impl/ConfigurationImplTest.java | 14 ++++++++++++++
1 file changed, 14 insertions(+)
diff --git
a/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImplTest.java
b/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImplTest.java
index ef0774f198..064b552ddd 100644
---
a/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImplTest.java
+++
b/artemis-server/src/test/java/org/apache/activemq/artemis/core/config/impl/ConfigurationImplTest.java
@@ -768,6 +768,20 @@ public class ConfigurationImplTest extends
ActiveMQTestBase {
Assert.assertEquals("foo",
amqpMirrorBrokerConnectionElement.getAddressFilter());
}
+
+ @Test
+ public void testAMQPConnectionsConfigurationUriEnc() throws Throwable {
+ ConfigurationImpl configuration = new ConfigurationImpl();
+
+ Properties insertionOrderedProperties = new
ConfigurationImpl.InsertionOrderedProperties();
+ insertionOrderedProperties.put("AMQPConnections.target.uri",
"tcp://amq-dc1-tls-amqp-${STATEFUL_SET_ORDINAL}-svc.dc1.svc.cluster.local:5673?clientFailureCheckPeriod=30000&connectionTTL=60000&sslEnabled=true&verifyHost=false&trustStorePath=/remote-cluster-truststore/client.ts");
+
insertionOrderedProperties.put("AMQPConnections.target.transportConfigurations.target.params.trustStorePassword","ENC(2a7c211d21c295cdbcde3589c205decb)");
+
+ configuration.parsePrefixedProperties(insertionOrderedProperties, null);
+ AMQPBrokerConnectConfiguration connectConfiguration =
configuration.getAMQPConnections().get(0);
+
Assert.assertFalse(connectConfiguration.getTransportConfigurations().get(0).getParams().get("trustStorePassword").toString().contains("ENC"));
+ }
+
@Test
public void testCoreBridgeConfiguration() throws Throwable {
ConfigurationImpl configuration = new ConfigurationImpl();