From 7bbe3250d06c79d0ff2233df3364b722e26c80ca Mon Sep 17 00:00:00 2001 From: Soby Chacko Date: Sat, 23 Jul 2022 19:16:54 -0400 Subject: [PATCH] PulsarContainerProperties cleanup --- .../listener/PulsarContainerProperties.java | 20 ------------------- 1 file changed, 20 deletions(-) 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; }