Prevent warnings when running embedded Artemis

Configure AddressSettings for DLQ and ExpiryQueue for the embedded
Artemis broker to prevent warnings from being logged.

Closes gh-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);
+	}
 }