Skip to content

Commit d96cc21

Browse files
committed
Upgrade to Artemis 2.35.0
Closes gh-41400
1 parent 16d4329 commit d96cc21

File tree

5 files changed

+11
-13
lines changed

5 files changed

+11
-13
lines changed

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

Lines changed: 4 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2012-2023 the original author or authors.
2+
* Copyright 2012-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -69,16 +69,15 @@ Configuration createConfiguration() {
6969
configuration.setClusterPassword(this.properties.getClusterPassword());
7070
configuration.addAddressConfiguration(createAddressConfiguration("DLQ"));
7171
configuration.addAddressConfiguration(createAddressConfiguration("ExpiryQueue"));
72-
configuration.addAddressSetting("#",
73-
new AddressSettings().setDeadLetterAddress(SimpleString.toSimpleString("DLQ"))
74-
.setExpiryAddress(SimpleString.toSimpleString("ExpiryQueue")));
72+
configuration.addAddressSetting("#", new AddressSettings().setDeadLetterAddress(SimpleString.of("DLQ"))
73+
.setExpiryAddress(SimpleString.of("ExpiryQueue")));
7574
return configuration;
7675
}
7776

7877
private CoreAddressConfiguration createAddressConfiguration(String name) {
7978
return new CoreAddressConfiguration().setName(name)
8079
.addRoutingType(RoutingType.ANYCAST)
81-
.addQueueConfiguration(new QueueConfiguration(name).setRoutingType(RoutingType.ANYCAST).setAddress(name));
80+
.addQueueConfiguration(QueueConfiguration.of(name).setRoutingType(RoutingType.ANYCAST).setAddress(name));
8281
}
8382

8483
private String getDataDir() {

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

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,5 +1,5 @@
11
/*
2-
* Copyright 2012-2023 the original author or authors.
2+
* Copyright 2012-2024 the original author or authors.
33
*
44
* Licensed under the Apache License, Version 2.0 (the "License");
55
* you may not use this file except in compliance with the License.
@@ -68,7 +68,8 @@ EmbeddedActiveMQ embeddedActiveMq(org.apache.activemq.artemis.core.config.Config
6868
String queueName = queueConfiguration.getName();
6969
configuration.addAddressConfiguration(new CoreAddressConfiguration().setName(queueName)
7070
.addRoutingType(RoutingType.ANYCAST)
71-
.addQueueConfiguration(new QueueConfiguration(queueName).setAddress(queueName)
71+
.addQueueConfiguration(QueueConfiguration.of(queueName)
72+
.setAddress(queueName)
7273
.setFilterString(queueConfiguration.getSelector())
7374
.setDurable(queueConfiguration.isDurable())
7475
.setRoutingType(RoutingType.ANYCAST)));

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

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -449,7 +449,7 @@ void checkTopic(String name, boolean shouldExist) {
449449

450450
void checkDestination(String name, RoutingType routingType, boolean shouldExist) {
451451
try {
452-
BindingQueryResult result = this.server.bindingQuery(new SimpleString(name));
452+
BindingQueryResult result = this.server.bindingQuery(SimpleString.of(name));
453453
assertThat(result.isExists()).isEqualTo(shouldExist);
454454
if (shouldExist) {
455455
assertThat(result.getAddressInfo().getRoutingType()).isEqualTo(routingType);

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

Lines changed: 2 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -75,10 +75,8 @@ void hasDlqExpiryQueueAddressSettingsConfigured() {
7575
ArtemisProperties properties = new ArtemisProperties();
7676
Configuration configuration = new ArtemisEmbeddedConfigurationFactory(properties).createConfiguration();
7777
Map<String, AddressSettings> addressSettings = configuration.getAddressSettings();
78-
assertThat((Object) addressSettings.get("#").getDeadLetterAddress())
79-
.isEqualTo(SimpleString.toSimpleString("DLQ"));
80-
assertThat((Object) addressSettings.get("#").getExpiryAddress())
81-
.isEqualTo(SimpleString.toSimpleString("ExpiryQueue"));
78+
assertThat((Object) addressSettings.get("#").getDeadLetterAddress()).isEqualTo(SimpleString.of("DLQ"));
79+
assertThat((Object) addressSettings.get("#").getExpiryAddress()).isEqualTo(SimpleString.of("ExpiryQueue"));
8280
}
8381

8482
@Test

spring-boot-project/spring-boot-dependencies/build.gradle

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -73,7 +73,7 @@ bom {
7373
releaseNotes("https://github.com/eclipse-ee4j/angus-mail/releases/tag/{version}")
7474
}
7575
}
76-
library("Artemis", "2.33.0") {
76+
library("Artemis", "2.35.0") {
7777
group("org.apache.activemq") {
7878
imports = [
7979
"artemis-bom"

0 commit comments

Comments
 (0)