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 efdcc56519 NO-JIRA add transformer to bridge properties config test
efdcc56519 is described below
commit efdcc56519923ef4dd952b2c23b08b8aba275c0c
Author: Gary Tully <[email protected]>
AuthorDate: Mon Jun 10 11:54:53 2024 +0100
NO-JIRA add transformer to bridge properties config test
---
.../activemq/artemis/core/config/impl/ConfigurationImplTest.java | 9 +++++++++
1 file changed, 9 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 a65dfb630a..713d2cf1b0 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
@@ -88,6 +88,7 @@ import
org.apache.activemq.artemis.core.server.impl.LegacyLDAPSecuritySettingPlu
import
org.apache.activemq.artemis.core.server.plugin.impl.ConnectionPeriodicExpiryPlugin;
import
org.apache.activemq.artemis.core.server.plugin.impl.LoggingActiveMQServerPlugin;
import org.apache.activemq.artemis.core.server.routing.KeyType;
+import
org.apache.activemq.artemis.core.server.transformer.AddHeadersTransformer;
import org.apache.activemq.artemis.core.settings.impl.AddressFullMessagePolicy;
import org.apache.activemq.artemis.core.settings.impl.DeletionPolicy;
import org.apache.activemq.artemis.core.settings.impl.ResourceLimitSettings;
@@ -680,7 +681,12 @@ public class ConfigurationImplTest extends
AbstractConfigurationTestBase {
// flip b in place
properties.put("bridgeConfigurations.b1.staticConnectors[1]", "c");
+
properties.put("bridgeConfigurations.b1.transformerConfiguration.className",
AddHeadersTransformer.class.getName());
+
properties.put("bridgeConfigurations.b1.transformerConfiguration.properties",
"header1=a,header2=b");
+
properties.put("bridgeConfigurations.b1.transformerConfiguration.properties.header3","c");
+
configuration.parsePrefixedProperties(properties, null);
+ assertTrue(configuration.getStatus().contains("\"errors\":[]"));
assertEquals(1, configuration.getBridgeConfigurations().size());
assertEquals(queueName,
configuration.getBridgeConfigurations().get(0).getQueueName());
@@ -693,6 +699,9 @@ public class ConfigurationImplTest extends
AbstractConfigurationTestBase {
assertEquals(ComponentConfigurationRoutingType.STRIP,
configuration.getBridgeConfigurations().get(0).getRoutingType());
+ assertEquals(3,
configuration.getBridgeConfigurations().get(0).getTransformerConfiguration().getProperties().size());
+ assertEquals(AddHeadersTransformer.class.getName(),
configuration.getBridgeConfigurations().get(0).getTransformerConfiguration().getClassName());
+
properties = new ConfigurationImpl.InsertionOrderedProperties();
// validate out of bound is trapped as error
properties.put("bridgeConfigurations.b1.staticConnectors[5]", "d");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
For further information, visit: https://activemq.apache.org/contact
