From ada6086cd8775da96bdbad6b10cd800ca199ddeb Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Tue, 30 Aug 2022 21:47:42 -0400 Subject: [PATCH] Verify Pulsar consumer enum values as properties When providing Pulsar consumer properties as Boot properties, if there are enum values, verify that they are translated properly as valid consumer properties. --- .../autoconfigure/PulsarAutoConfigurationTests.java | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarAutoConfigurationTests.java b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarAutoConfigurationTests.java index 4422b257..c9500a95 100644 --- a/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarAutoConfigurationTests.java +++ b/spring-pulsar-spring-boot-autoconfigure/src/test/java/org/springframework/pulsar/autoconfigure/PulsarAutoConfigurationTests.java @@ -21,6 +21,7 @@ import static org.mockito.Mockito.mock; import java.util.concurrent.TimeUnit; +import org.apache.pulsar.client.api.SubscriptionInitialPosition; import org.apache.pulsar.client.api.interceptor.ProducerInterceptor; import org.assertj.core.api.InstanceOfAssertFactories; import org.junit.jupiter.api.Nested; @@ -54,6 +55,7 @@ import org.springframework.pulsar.listener.DefaultPulsarMessageListenerContainer * * @author Chris Bono * @author Alexander Preuß + * @author Soby Chacko */ @SuppressWarnings("unchecked") class PulsarAutoConfigurationTests { @@ -139,6 +141,14 @@ class PulsarAutoConfigurationTests { .isSameAs(consumerFactory)); } + @Test + void pulsarConsumerFactoryWithEnumPropertyValue() { + this.contextRunner.withPropertyValues("spring.pulsar.consumer.subscriptionInitialPosition=Earliest") + .run((context -> assertThat(context).hasNotFailed().getBean(PulsarConsumerFactory.class) + .extracting("consumerConfig").hasFieldOrPropertyWithValue("subscriptionInitialPosition", + SubscriptionInitialPosition.Earliest))); + } + @Test void customPulsarListenerContainerFactoryIsRespected() { PulsarListenerContainerFactory> listenerContainerFactory = mock(