[rocketmq] branch develop updated (d9223ffd7 -> 2da6e9b2d)

[zh...@apache.org]

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

zhouxzhan pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


    from d9223ffd7 Update AclUtils.java (#6689)
     add 2da6e9b2d [ISSUE #6696] Refector proxy common and client module (#6697)

No new revisions were added by this update.

Summary of changes:
 .../client/common/NameserverAccessConfig.java      | 29 +++++++++++-----------
 .../mqclient/DoNothingClientRemotingProcessor.java |  2 +-
 .../client/impl}/mqclient/MQClientAPIExt.java      |  4 +--
 .../client/impl}/mqclient/MQClientAPIFactory.java  | 25 +++++++++----------
 .../common/utils}/AbstractStartAndShutdown.java    |  2 +-
 .../apache/rocketmq/common/utils}/Shutdown.java    |  2 +-
 .../org/apache/rocketmq/common/utils}/Start.java   |  2 +-
 .../rocketmq/common/utils}/StartAndShutdown.java   |  2 +-
 .../org/apache/rocketmq/proxy/ProxyStartup.java    |  4 +--
 .../org/apache/rocketmq/proxy/grpc/GrpcServer.java |  2 +-
 .../proxy/grpc/v2/DefaultGrpcMessingActivity.java  |  2 +-
 .../proxy/grpc/v2/GrpcMessagingApplication.java    |  2 +-
 .../proxy/grpc/v2/GrpcMessingActivity.java         |  2 +-
 .../proxy/grpc/v2/channel/GrpcChannelManager.java  |  2 +-
 .../grpc/v2/common/GrpcClientSettingsManager.java  |  2 +-
 .../proxy/metrics/ProxyMetricsManager.java         |  2 +-
 .../proxy/processor/AbstractProcessor.java         |  2 +-
 .../proxy/processor/DefaultMessagingProcessor.java |  2 +-
 .../proxy/processor/MessagingProcessor.java        |  2 +-
 .../proxy/processor/ReceiptHandleProcessor.java    |  4 +--
 .../proxy/remoting/RemotingProtocolServer.java     |  2 +-
 .../remoting/channel/RemotingChannelManager.java   |  2 +-
 .../proxy/service/ClusterServiceManager.java       | 14 ++++++++---
 .../proxy/service/LocalServiceManager.java         | 15 ++++++++---
 .../rocketmq/proxy/service/ServiceManager.java     |  2 +-
 .../proxy/service/admin/DefaultAdminService.java   |  4 +--
 .../service/client/ClusterConsumerManager.java     |  4 +--
 .../ProxyClientRemotingProcessor.java              |  2 +-
 .../service/message/ClusterMessageService.java     |  2 +-
 .../service/metadata/ClusterMetadataService.java   |  4 +--
 .../service/route/ClusterTopicRouteService.java    |  2 +-
 .../service/route/LocalTopicRouteService.java      |  2 +-
 .../proxy/service/route/TopicRouteService.java     |  4 +--
 .../sysmessage/AbstractSystemMessageSyncer.java    |  4 +--
 .../proxy/service/sysmessage/HeartbeatSyncer.java  |  2 +-
 .../transaction/AbstractTransactionService.java    |  2 +-
 .../transaction/ClusterTransactionService.java     |  2 +-
 .../transaction/TransactionDataManager.java        |  2 +-
 .../rocketmq/proxy/service/BaseServiceTest.java    |  4 +--
 .../service/admin/DefaultAdminServiceTest.java     |  4 +--
 .../service/message/ClusterMessageServiceTest.java |  2 +-
 .../proxy/service/mqclient/MQClientAPIExtTest.java |  2 ++
 .../mqclient/ProxyClientRemotingProcessorTest.java |  1 +
 .../service/sysmessage/HeartbeatSyncerTest.java    |  4 +--
 44 files changed, 99 insertions(+), 85 deletions(-)
 copy tools/src/main/java/org/apache/rocketmq/tools/monitor/MonitorConfig.java => client/src/main/java/org/apache/rocketmq/client/common/NameserverAccessConfig.java (62%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/service => client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/DoNothingClientRemotingProcessor.java (96%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/service => client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/MQClientAPIExt.java (99%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/service => client/src/main/java/org/apache/rocketmq/client/impl}/mqclient/MQClientAPIFactory.java (82%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/common => common/src/main/java/org/apache/rocketmq/common/utils}/AbstractStartAndShutdown.java (98%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/common => common/src/main/java/org/apache/rocketmq/common/utils}/Shutdown.java (95%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/common => common/src/main/java/org/apache/rocketmq/common/utils}/Start.java (95%)
 rename {proxy/src/main/java/org/apache/rocketmq/proxy/common => common/src/main/java/org/apache/rocketmq/common/utils}/StartAndShutdown.java (95%)
 rename proxy/src/main/java/org/apache/rocketmq/proxy/service/{mqclient => client}/ProxyClientRemotingProcessor.java (98%)