Spring/spring-pulsar
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Fix ReactivePulsarListenerIntegrationTests use of customizer (#501)

Browse Source
This commit is contained in:
Chris Bono
2023-11-23 15:15:30 -06:00
committed by GitHub
parent 062054106f
commit 6155fd593b
2 changed files with 4 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
integration-tests/integration-tests.gradle
View File

@@ -13,6 +13,8 @@ repositories {
}
dependencies {
intTestImplementation project(':spring-pulsar')
intTestImplementation project(':spring-pulsar-reactive')
intTestImplementation project(':spring-pulsar-test')
intTestRuntimeOnly 'ch.qos.logback:logback-classic'
intTestRuntimeOnly 'org.junit.platform:junit-platform-launcher'

4
integration-tests/src/intTest/java/org/springframework/pulsar/inttest/listener/ReactivePulsarListenerIntegrationTests.java
View File

@@ -42,7 +42,7 @@ import org.springframework.pulsar.core.PulsarTemplate;
import org.springframework.pulsar.core.SchemaResolver;
import org.springframework.pulsar.core.TopicResolver;
import org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListener;
import org.springframework.pulsar.reactive.core.ReactiveMessageConsumerBuilderCustomizer;
import org.springframework.pulsar.reactive.config.annotation.ReactivePulsarListenerMessageConsumerBuilderCustomizer;
import org.springframework.pulsar.reactive.core.ReactivePulsarTemplate;
import org.springframework.pulsar.test.support.PulsarTestContainerSupport;
@@ -221,7 +221,7 @@ class ReactivePulsarListenerIntegrationTests implements PulsarTestContainerSuppo
static class ConsumerCustomizerConfig {
@Bean
ReactiveMessageConsumerBuilderCustomizer<String> consumerCustomizer() {
ReactivePulsarListenerMessageConsumerBuilderCustomizer<String> consumerCustomizer() {
return b -> b.subscriptionInitialPosition(SubscriptionInitialPosition.Earliest);
}