Prevent warnings when running embedded Artemis

Configure AddressSettings for DLQ and ExpiryQueue for the embedded Artemis broker to prevent warnings from being logged. Closes spring-projectsgh-12680

Author: graben

spring-boot-project/spring-boot-autoconfigure/src/main/java/org/springframework/boot/autoconfigure/jms/artemis/ArtemisEmbeddedConfigurationFactory.java

@@ -18,11 +18,16 @@
 
 import java.io.File;
 
+import org.apache.activemq.artemis.api.core.RoutingType;
+import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.api.core.TransportConfiguration;
 import org.apache.activemq.artemis.core.config.Configuration;
+import org.apache.activemq.artemis.core.config.CoreAddressConfiguration;
+import org.apache.activemq.artemis.core.config.CoreQueueConfiguration;
 import org.apache.activemq.artemis.core.config.impl.ConfigurationImpl;
 import org.apache.activemq.artemis.core.remoting.impl.invm.InVMAcceptorFactory;
 import org.apache.activemq.artemis.core.server.JournalType;
+import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
 import org.apache.commons.logging.Log;
 import org.apache.commons.logging.LogFactory;
 
@@ -65,6 +70,26 @@ public Configuration createConfiguration() {
 + this.properties.getClusterPassword());
 }
 configuration.setClusterPassword(this.properties.getClusterPassword());
+configuration.addAddressesSetting("#",
+new AddressSettings()
+.setDeadLetterAddress(SimpleString.toSimpleString("DLQ"))
+.setExpiryAddress(SimpleString.toSimpleString("ExpiryQueue")));
+configuration.addAddressConfiguration(
+new CoreAddressConfiguration()
+.setName("DLQ")
+.addRoutingType(RoutingType.ANYCAST)
+.addQueueConfiguration(
+new CoreQueueConfiguration()
+.setName("DLQ")
+.setRoutingType(RoutingType.ANYCAST)));
+configuration.addAddressConfiguration(
+new CoreAddressConfiguration()
+.setName("ExpiryQueue")
+.addRoutingType(RoutingType.ANYCAST)
+.addQueueConfiguration(
+new CoreQueueConfiguration()
+.setName("ExpiryQueue")
+.setRoutingType(RoutingType.ANYCAST)));
 return configuration;
 }
 

spring-boot-project/spring-boot-autoconfigure/src/test/java/org/springframework/boot/autoconfigure/jms/artemis/ArtemisEmbeddedConfigurationFactoryTests.java

@@ -16,8 +16,14 @@
 
 package org.springframework.boot.autoconfigure.jms.artemis;
 
+import java.util.List;
+import java.util.Map;
+
+import org.apache.activemq.artemis.api.core.SimpleString;
 import org.apache.activemq.artemis.core.config.Configuration;
+import org.apache.activemq.artemis.core.config.CoreAddressConfiguration;
 import org.apache.activemq.artemis.core.server.JournalType;
+import org.apache.activemq.artemis.core.settings.impl.AddressSettings;
 import org.junit.Test;
 
 import static org.assertj.core.api.Assertions.assertThat;
@@ -68,4 +74,22 @@ public void specificClusterPassword() {
 assertThat(configuration.getClusterPassword()).isEqualTo("password");
 }
 
+@Test
+public void hasDlqExpiryQueueAddressSettingsConfigured() {
+ArtemisProperties properties = new ArtemisProperties();
+Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties)
+.createConfiguration();
+Map<String, AddressSettings> addressesSettings = configuration.getAddressesSettings();
+assertThat((CharSequence) addressesSettings.get("#").getDeadLetterAddress()).isEqualTo(SimpleString.toSimpleString("DLQ"));
+assertThat((CharSequence) addressesSettings.get("#").getExpiryAddress()).isEqualTo(SimpleString.toSimpleString("ExpiryQueue"));
+}
+
+@Test
+public void hasDlqExpiryQueueConfigured() {
+ArtemisProperties properties = new ArtemisProperties();
+Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties)
+.createConfiguration();
+List<CoreAddressConfiguration> addressConfigurations = configuration.getAddressConfigurations();
+assertThat(addressConfigurations).hasSize(2);
+}
 }