|
20 | 20 | import org.testcontainers.elasticsearch.ElasticsearchContainer;
|
21 | 21 | import org.testcontainers.junit.jupiter.Container;
|
22 | 22 | import org.testcontainers.junit.jupiter.Testcontainers;
|
| 23 | +import reactor.core.publisher.Mono; |
23 | 24 |
|
24 | 25 | import org.springframework.boot.autoconfigure.AutoConfigurations;
|
25 | 26 | import org.springframework.boot.autoconfigure.TestAutoConfigurationPackage;
|
|
30 | 31 | import org.springframework.boot.autoconfigure.elasticsearch.ElasticsearchClientAutoConfiguration;
|
31 | 32 | import org.springframework.boot.autoconfigure.elasticsearch.ElasticsearchRestClientAutoConfiguration;
|
32 | 33 | import org.springframework.boot.autoconfigure.elasticsearch.ReactiveElasticsearchClientAutoConfiguration;
|
| 34 | +import org.springframework.boot.test.context.FilteredClassLoader; |
33 | 35 | import org.springframework.boot.test.context.runner.ApplicationContextRunner;
|
34 | 36 | import org.springframework.boot.testsupport.container.TestImage;
|
35 | 37 | import org.springframework.context.annotation.Configuration;
|
@@ -62,6 +64,14 @@ class ReactiveElasticsearchRepositoriesAutoConfigurationTests {
|
62 | 64 | "spring.elasticsearch.uris=" + elasticsearch.getHost() + ":" + elasticsearch.getFirstMappedPort(),
|
63 | 65 | "spring.elasticsearch.socket-timeout=30s");
|
64 | 66 |
|
| 67 | + @Test |
| 68 | + void backsOffWithoutReactor() { |
| 69 | + this.contextRunner.withUserConfiguration(TestConfiguration.class) |
| 70 | + .withClassLoader(new FilteredClassLoader(Mono.class)) |
| 71 | + .run((context) -> assertThat(context) |
| 72 | + .doesNotHaveBean(ReactiveElasticsearchRepositoriesAutoConfiguration.class)); |
| 73 | + } |
| 74 | + |
65 | 75 | @Test
|
66 | 76 | void testDefaultRepositoryConfiguration() {
|
67 | 77 | this.contextRunner.withUserConfiguration(TestConfiguration.class)
|
|
0 commit comments