Upgrade to Artemis 2.23.1

Closes gh-31583
pull/31663/head
Andy Wilkinson 2 years ago
parent 9e3c557992
commit 344a216feb

@ -69,7 +69,7 @@ class ArtemisEmbeddedConfigurationFactory {
configuration.setClusterPassword(this.properties.getClusterPassword()); configuration.setClusterPassword(this.properties.getClusterPassword());
configuration.addAddressConfiguration(createAddressConfiguration("DLQ")); configuration.addAddressConfiguration(createAddressConfiguration("DLQ"));
configuration.addAddressConfiguration(createAddressConfiguration("ExpiryQueue")); configuration.addAddressConfiguration(createAddressConfiguration("ExpiryQueue"));
configuration.addAddressesSetting("#", configuration.addAddressSetting("#",
new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLQ")) new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLQ"))
.setExpiryAddress(SimpleString.toSimpleString("ExpiryQueue"))); .setExpiryAddress(SimpleString.toSimpleString("ExpiryQueue")));
return configuration; return configuration;

@ -74,10 +74,10 @@ class ArtemisEmbeddedConfigurationFactoryTests {
void hasDlqExpiryQueueAddressSettingsConfigured() { void hasDlqExpiryQueueAddressSettingsConfigured() {
ArtemisProperties properties = new ArtemisProperties(); ArtemisProperties properties = new ArtemisProperties();
Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties).createConfiguration(); Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties).createConfiguration();
Map<String, AddressSettings> addressesSettings = configuration.getAddressesSettings(); Map<String, AddressSettings> addressSettings = configuration.getAddressSettings();
assertThat((Object) addressesSettings.get("#").getDeadLetterAddress()) assertThat((Object) addressSettings.get("#").getDeadLetterAddress())
.isEqualTo(SimpleString.toSimpleString("DLQ")); .isEqualTo(SimpleString.toSimpleString("DLQ"));
assertThat((Object) addressesSettings.get("#").getExpiryAddress()) assertThat((Object) addressSettings.get("#").getExpiryAddress())
.isEqualTo(SimpleString.toSimpleString("ExpiryQueue")); .isEqualTo(SimpleString.toSimpleString("ExpiryQueue"));
} }

@ -24,7 +24,7 @@ bom {
] ]
} }
} }
library("Artemis", "2.22.0") { library("Artemis", "2.23.1") {
group("org.apache.activemq") { group("org.apache.activemq") {
modules = [ modules = [
"artemis-amqp-protocol", "artemis-amqp-protocol",

Loading…
Cancel
Save