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

Remove initialSubscriptionName from producer/sender properties (#215)

Browse Source 
initialSubscriptionName is an internal param used by the Pulsar client for DLT.
It is not used in the reactive client and should be removed from MutableReactiveMessageSenderSpec
This commit is contained in:
Christophe Bornet
2022-11-17 21:23:33 +01:00
committed by GitHub
parent 0a6c75e2ab
commit 3ffb52e22c
2 changed files with 0 additions and 28 deletions
Download Patch File Download Diff File Expand all files Collapse all files

14
spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarProperties.java
View File

@@ -527,11 +527,6 @@ public class PulsarProperties {
*/
private CompressionType compressionType;
/**
* Name of the initial subscription of the topic.
*/
private String initialSubscriptionName;
/**
* Type of access to the topic the producer requires.
*/
@@ -651,14 +646,6 @@ public class PulsarProperties {
this.compressionType = compressionType;
}
public String getInitialSubscriptionName() {
return this.initialSubscriptionName;
}
public void setInitialSubscriptionName(String initialSubscriptionName) {
this.initialSubscriptionName = initialSubscriptionName;
}
public ProducerAccessMode getProducerAccessMode() {
return this.producerAccessMode;
}
@@ -692,7 +679,6 @@ public class PulsarProperties {
map.from(this::isBatchingEnabled).to(properties.in("batchingEnabled"));
map.from(this::isChunkingEnabled).to(properties.in("chunkingEnabled"));
map.from(this::getCompressionType).to(properties.in("compressionType"));
map.from(this::getInitialSubscriptionName).to(properties.in("initialSubscriptionName"));
map.from(this::getProducerAccessMode).to(properties.in("accessMode"));
return properties;

14
spring-pulsar-spring-boot-autoconfigure/src/main/java/org/springframework/pulsar/autoconfigure/PulsarReactiveProperties.java
View File

@@ -166,11 +166,6 @@ public class PulsarReactiveProperties {
*/
private CompressionType compressionType;
/**
* Name of the initial subscription of the topic.
*/
private String initialSubscriptionName;
/**
* Type of access to the topic the producer requires.
*/
@@ -282,14 +277,6 @@ public class PulsarReactiveProperties {
this.compressionType = compressionType;
}
public String getInitialSubscriptionName() {
return this.initialSubscriptionName;
}
public void setInitialSubscriptionName(String initialSubscriptionName) {
this.initialSubscriptionName = initialSubscriptionName;
}
public ProducerAccessMode getProducerAccessMode() {
return this.producerAccessMode;
}
@@ -320,7 +307,6 @@ public class PulsarReactiveProperties {
map.from(this::getBatchingEnabled).to(spec::setBatchingEnabled);
map.from(this::getChunkingEnabled).to(spec::setChunkingEnabled);
map.from(this::getCompressionType).to(spec::setCompressionType);
map.from(this::getInitialSubscriptionName).to(spec::setInitialSubscriptionName);
map.from(this::getProducerAccessMode).to(spec::setAccessMode);
return new ImmutableReactiveMessageSenderSpec(spec);