diff --git a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarContainerProperties.java b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarContainerProperties.java index 48953ff1..7591fcb9 100644 --- a/spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarContainerProperties.java +++ b/spring-pulsar/src/main/java/org/springframework/pulsar/listener/PulsarContainerProperties.java @@ -79,10 +79,6 @@ public class PulsarContainerProperties { private boolean batchListener; - private boolean batchAsyncReceive; - - private boolean asyncReceive; - private AckMode ackMode = AckMode.BATCH; public PulsarContainerProperties(String... topics) { @@ -151,22 +147,6 @@ public class PulsarContainerProperties { this.batchListener = batchListener; } - public boolean isBatchAsyncReceive() { - return this.batchAsyncReceive; - } - - public void setBatchAsyncReceive(boolean batchAsyncReceive) { - this.batchAsyncReceive = batchAsyncReceive; - } - - public boolean isAsyncReceive() { - return this.asyncReceive; - } - - public void setAsyncReceive(boolean asyncReceive) { - this.asyncReceive = asyncReceive; - } - public AckMode getAckMode() { return this.ackMode; }