From fe6d8871f438c5a2e75997c20080ef59470a3803 Mon Sep 17 00:00:00 2001 From: Chris Bono Date: Wed, 22 Nov 2023 20:33:36 -0600 Subject: [PATCH] Fix failure in PulsarExtendedBindingPropertiesTests The default value for PulsarContainerProperties.subscriptionType was switched to `null` in https://github.com/spring-projects/spring-pulsar/commit/ed3899fcb9aee8e6767cdbe8275055a47fd22c47#diff-1371e1026362d375ef0f90846291add7cdcae0c340b934e3972d0bd72b312fa5L61. This commit adjusts the PulsarExtendedBindingPropertiesTests 'extendedBindingsArePropagatedToContainerProperties' test for this fact. --- .../binder/pulsar/PulsarExtendedBindingPropertiesTests.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java index f9fa9def1..9df2491aa 100644 --- a/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java +++ b/binders/pulsar-binder/spring-cloud-stream-binder-pulsar/src/test/java/org/springframework/cloud/stream/binder/pulsar/PulsarExtendedBindingPropertiesTests.java @@ -97,7 +97,7 @@ class PulsarExtendedBindingPropertiesTests { PulsarContainerProperties pulsarContainerProperties = new PulsarContainerProperties(); pulsarContainerProperties.getPulsarConsumerProperties().putAll(consumerProps); assertThat(pulsarContainerProperties.getSubscriptionName()).isNull(); - assertThat(pulsarContainerProperties.getSubscriptionType()).isEqualTo(SubscriptionType.Exclusive); + assertThat(pulsarContainerProperties.getSubscriptionType()).isNull(); pulsarContainerProperties.updateContainerProperties(); assertThat(pulsarContainerProperties.getSubscriptionName()).isEqualTo("my-foo-sbscription"); assertThat(pulsarContainerProperties.getSubscriptionType()).isEqualTo(SubscriptionType.Shared);