[pulsar] branch master updated (f8a697d -> dbc0649)

[pe...@apache.org]

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 f8a697d  Prevent redirection of lookup requests from looping (#7200)
     add dbc0649  Add broker interceptor for Intercepting all Pulsar command and REST API requests. (#7143)

No new revisions were added by this update.

Summary of changes:
 .../apache/pulsar/broker/ServiceConfiguration.java |  12 ++
 .../org/apache/pulsar/broker/PulsarService.java    |   7 +-
 .../pulsar/broker/intercept/BrokerInterceptor.java |  92 ++++++++++++
 .../BrokerInterceptorDefinition.java}              |  15 +-
 .../BrokerInterceptorDefinitions.java}             |  13 +-
 .../BrokerInterceptorMetadata.java}                |  14 +-
 .../broker/intercept/BrokerInterceptorUtils.java   | 155 +++++++++++++++++++++
 .../BrokerInterceptorWithClassLoader.java}         |  51 +++----
 .../broker/intercept/BrokerInterceptors.java       | 112 +++++++++++++++
 .../pulsar/broker/intercept}/package-info.java     |   5 +-
 .../pulsar/broker/service/BrokerService.java       |  11 ++
 .../apache/pulsar/broker/service/ServerCnx.java    |  27 ++++
 ...estSizeFilter.java => EventListenerFilter.java} |  39 ++----
 .../org/apache/pulsar/broker/web/WebService.java   |   3 +
 .../broker/auth/MockedPulsarServiceBaseTest.java   |   4 +-
 .../broker/intercept/BrokerInterceptorTest.java    | 111 +++++++++++++++
 .../intercept/BrokerInterceptorUtilsTest.java      | 146 +++++++++++++++++++
 .../BrokerInterceptorWithClassLoaderTest.java      |  38 ++---
 .../CounterBrokerInterceptor.java}                 |  51 ++++---
 .../MockBrokerInterceptor.java}                    |  39 ++----
 .../pulsar/common/protocol/PulsarDecoder.java      |   7 +-
 21 files changed, 788 insertions(+), 164 deletions(-)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptor.java
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/{protocol/ProtocolHandlerDefinition.java => intercept/BrokerInterceptorDefinition.java} (74%)
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/{protocol/ProtocolHandlerDefinitions.java => intercept/BrokerInterceptorDefinitions.java} (81%)
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/{protocol/ProtocolHandlerMetadata.java => intercept/BrokerInterceptorMetadata.java} (82%)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtils.java
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/{protocol/ProtocolHandlerWithClassLoader.java => intercept/BrokerInterceptorWithClassLoader.java} (56%)
 create mode 100644 pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept/BrokerInterceptors.java
 copy {pulsar-common/src/main/java/org/apache/pulsar/common/io => pulsar-broker/src/main/java/org/apache/pulsar/broker/intercept}/package-info.java (91%)
 copy pulsar-broker/src/main/java/org/apache/pulsar/broker/web/{MaxRequestSizeFilter.java => EventListenerFilter.java} (51%)
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorTest.java
 create mode 100644 pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorUtilsTest.java
 copy pulsar-client/src/test/java/org/apache/pulsar/client/impl/ClientInitializationTest.java => pulsar-broker/src/test/java/org/apache/pulsar/broker/intercept/BrokerInterceptorWithClassLoaderTest.java (54%)
 copy pulsar-broker/src/test/java/org/apache/pulsar/broker/{protocol/MockProtocolHandler.java => intercept/CounterBrokerInterceptor.java} (50%)
 copy pulsar-broker/src/test/java/org/apache/pulsar/broker/{protocol/MockProtocolHandler.java => intercept/MockBrokerInterceptor.java} (56%)