This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new 74a498a2c10 [cleanup][broker] Remove legacy code (#18330)
74a498a2c10 is described below

commit 74a498a2c10bd1cc8f8f373c14f4c0d1fd6e07c3
Author: AloysZhang <[email protected]>
AuthorDate: Sat Nov 19 13:33:01 2022 +0800

    [cleanup][broker] Remove legacy code (#18330)
---
 .../java/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 85f23426290..864fe7f5d65 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 @@ public abstract class AbstractTopic implements Topic, 
TopicPolicyListener<TopicP
         }
     }
 
-    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());

Reply via email to