From 62f4a6ac774de85a12994c4b53352057d05ca944 Mon Sep 17 00:00:00 2001 From: aloyszhang Date: Fri, 4 Nov 2022 10:41:10 +0800 Subject: [PATCH] remove legacy code --- .../org/apache/pulsar/broker/service/AbstractTopic.java | 9 --------- 1 file changed, 9 deletions(-) diff --git a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java index 85f23426290c9..864fe7f5d65e1 100644 --- a/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java +++ b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/AbstractTopic.java @@ -937,15 +937,6 @@ protected void enableProducerReadForPublishRateLimiting() { } } - protected void enableProducerReadForPublishBufferLimiting() { - if (producers != null) { - producers.values().forEach(producer -> { - producer.getCnx().cancelPublishBufferLimiting(); - producer.getCnx().enableCnxAutoRead(); - }); - } - } - protected void disableProducerRead() { if (producers != null) { producers.values().forEach(producer -> producer.getCnx().disableCnxAutoRead());