This commit is contained in:
Phillip Webb
2023-08-13 20:40:57 -07:00
parent d73d8f8e4f
commit 407fa780c8
4 changed files with 13 additions and 7 deletions

View File

@@ -31,22 +31,25 @@ public enum Threading {
* Platform threads. Active if virtual threads are not active.
*/
PLATFORM {
@Override
public boolean isActive(Environment environment) {
return !VIRTUAL.isActive(environment);
}
},
/**
* Virtual threads. Active if {@code spring.threads.virtual.enabled} is {@code true}
* and running on Java 21 or later.
*/
VIRTUAL {
@Override
public boolean isActive(Environment environment) {
boolean virtualThreadsEnabled = environment.getProperty("spring.threads.virtual.enabled", boolean.class,
false);
return virtualThreadsEnabled && JavaVersion.getJavaVersion().isEqualOrNewerThan(JavaVersion.TWENTY_ONE);
return environment.getProperty("spring.threads.virtual.enabled", boolean.class, false)
&& JavaVersion.getJavaVersion().isEqualOrNewerThan(JavaVersion.TWENTY_ONE);
}
};
/**

View File

@@ -289,6 +289,7 @@ class ActiveMQAutoConfigurationTests {
@Bean
ActiveMQConnectionDetails activemqConnectionDetails() {
return new ActiveMQConnectionDetails() {
@Override
public String getBrokerUrl() {
return "tcp://localhost:12345";
@@ -303,6 +304,7 @@ class ActiveMQAutoConfigurationTests {
public String getPassword() {
return "spring";
}
};
}