PulsarContainerProperties cleanup

This commit is contained in:
Soby Chacko
2022-07-23 19:16:54 -04:00
parent fde611328c
commit 7bbe3250d0

View File

@@ -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;
}