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

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


    from a7f692f  [pulsar-broker] capture stats with precise backlog (#8928)
     add f76655a  Intercept beforeSendMessage calls (#8932)

No new revisions were added by this update.

Summary of changes:
 .../pulsar/broker/intercept/BrokerInterceptor.java | 17 +++++++++++++
 .../BrokerInterceptorWithClassLoader.java          | 12 +++++++++
 .../broker/intercept/BrokerInterceptors.java       | 17 +++++++++++++
 .../broker/service/AbstractBaseDispatcher.java     | 15 ++++++++++-
 .../apache/pulsar/broker/service/Subscription.java |  3 +++
 .../nonpersistent/NonPersistentSubscription.java   |  6 +++++
 .../service/persistent/PersistentSubscription.java |  6 +++++
 .../broker/intercept/BrokerInterceptorTest.java    | 29 ++++++++++++++++++++++
 .../broker/intercept/CounterBrokerInterceptor.java | 18 ++++++++++++++
 9 files changed, 122 insertions(+), 1 deletion(-)

Reply via email to