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

Container properties code optimization

Browse Source
This commit is contained in:
Soby Chacko
2023-03-29 20:16:52 -04:00
parent 42daa54d33
commit 0969efe14c
1 changed files with 10 additions and 7 deletions
Download Patch File Download Diff File Expand all files Collapse all files

17
spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarContainerProperties.java
View File

@@ -19,6 +19,7 @@ package org.springframework.pulsar.listener;
import java.time.Duration;
import java.util.Properties;
import java.util.Set;
import java.util.function.Consumer;
import org.apache.pulsar.client.api.Schema;
import org.apache.pulsar.client.api.SubscriptionType;
@@ -252,13 +253,15 @@ public class PulsarContainerProperties {
}
public void updateContainerProperties() {
if (!this.pulsarConsumerProperties.isEmpty()) {
if (this.pulsarConsumerProperties.containsKey(SUBSCRIPTION_NAME)) {
this.subscriptionName = (String) this.pulsarConsumerProperties.get(SUBSCRIPTION_NAME);
}
if (this.pulsarConsumerProperties.containsKey(SUBSCRIPTION_TYPE)) {
this.subscriptionType = (SubscriptionType) this.pulsarConsumerProperties.get(SUBSCRIPTION_TYPE);
}
applyPropIfSpecified(SUBSCRIPTION_NAME, this::setSubscriptionName);
applyPropIfSpecified(SUBSCRIPTION_TYPE, this::setSubscriptionType);
}
@SuppressWarnings("unchecked")
private <T> void applyPropIfSpecified(String key, Consumer<T> setter) {
if (this.pulsarConsumerProperties.containsKey(key)) {
T value = (T) this.pulsarConsumerProperties.get(key);
setter.accept(value);
}
}