You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/07/20 02:36:31 UTC
[rocketmq] branch develop updated (89cb8cce8 -> e6b4e15eb)
This is an automated email from the ASF dual-hosted git repository.
linhill pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 89cb8cce8 [ISSUE #4630] Fix RequestTask's stopRun field concurrency issues(#4631) (#4631)
new 8d203e847 [ISSUE #3949] Add rocketmq-proto dependency.
new 3134916c5 [ISSUE #3949] Initialize basic structure
new 57a549a95 [ISSUE #3949] Add interface for GrpcService
new dcfa88bca [ISSUE #3949] Init proxyStartup.
new 876f31c31 [ISSUE #3949] Add UT for configuration package.
new 763e874b2 [ISSUE #3949] can config bootstrap thread num; disable callbackExecutor and nettyWorkerGroup in NettyClientConfig
new ca3de6a31 [ISSUE #3949] add client for proxy in cluster mode
new 80b2f95d1 [ISSUE #3949] Support sendMessage in Local mode
new 4059688c7 [ISSUE #3949] Add HeaderInterceptor
new 38ab97cc3 [ISSUE #3949] Use CompletableFuture
new 6fcefe10e [ISSUE #3949] Add sendMessage in GrpcMessagingProcessor
new b7c9e97f2 [ISSUE #3949] Add UT for LocalGrpcService
new e319024fa [ISSUE #3949] Add logger config and rename GrpcService to GrpcForwardService.
new 23c14ff73 [ISSUE #3949] Add Base Initialization for test cases.
new 64f22d910 [ISSUE #3949] Add UT for clientManager.
new 8d924e9e6 [ISSUE #3949] refactor SelectableMessageQueue.
new 115030a80 [ISSUE #3949] Refector SimpleChannel
new 9e2dc9329 [ISSUE #3949] Add code in GrpcMessagingProcessor
new f5df79939 [ISSUE #3949] Add heartbeat in LocalGrpcService
new 85d4a368c [ISSUE #3949] Add Converter.buildPopMessageRequestHeader
new 0e5dee8b4 [ISSUE #3949] queryRoute, queryAssignment, sendMessage for cluster mode
new be512d574 [ISSUE #3949] refactor SelectableMessageQueue and do the merging work.
new 3b437435b [ISSUE #3949] do some renaming work.
new 6b985f766 [ISSUE #3949] Fix unit test
new 60868dafc [ISSUE #3949] Add receiveMessage
new 0cd8ff08e [ISSUE #3949] Remove consumerGroupInfo in PopMessageProcessor
new 19161001f [ISSUE #3949] Add IT
new 902f09c92 [ISSUE #3949] Fix codes for passing style checking.
new 540ccd741 [ISSUE #3949] add grpc channel impl
new db7ab9b61 [ISSUE #3949] Refector Channels
new 63211bdcf [ISSUE #3949] Do some renaming work.
new 5c6fccacc [ISSUE #3949] Do some renaming work.
new 77d7da51c [ISSUE #3949] Implement ack and nack
new f07904a70 [ISSUE #3949] Simplify Channels
new 42ee31ec4 [ISSUE #3949] Implement ForwardMessageToDeadLetterQueue
new 89e0727b7 [ISSUE #3949] receiveMessage for cluster mode; code refactor for queryRoute, queryAssignment, sendMessage
new c456ea788 [ISSUE #3949] Implement pollCommand
new 67440ebe2 [ISSUE #3949] pollCommand for cluster mode
new 5cbb01e37 [ISSUE #3949] Implement Local transaction module
new 10a7b3c9a [ISSUE #3949] ack, nack for cluster mode
new 1150aa994 [ISSUE #3949] pull message for cluster mode and code refactor
new fe96159a4 [ISSUE #3949] transaction support for cluster mode
new b425608b1 [ISSUE #3949] Refactor partition generation and add unit test.
new e44f29a64 [ISSUE #3949] forwardMsgToDLQ for cluster mode; add ProducerGroupOfflineListener
new 7f4b7bce2 [ISSUE #3949] Do refactor work for passing check style.
new d0ed25e93 [ISSUE #3949] Implement route in Local mode
new 806def231 [ISSUE #3949] Support PollCommand
new 153b2ddd4 [ISSUE #3949] Implement notifyClientTermination and changeInvisibleDuration
new 527a38cef [ISSUE #3949] Implement pull and stream
new 83e9d838d [ISSUE #3949] Do some refactoring for passing check style.
new afc2aeab6 [ISSUE #3949] Do some refactoring for readability.
new 5c8374c43 [ISSUE #3949] Add unit test
new 053c6437f [ISSUE #3949] Add DelayPolicy
new a96b21448 [ISSUE #3949] Improve readability.
new f9c3a5e49 [ISSUE #3949] Improve readability.
new 1dc5b7c41 [ISSUE #3949] Improve readability.
new 3f07761f6 [ISSUE #3949] ack msg when tag not match; refactor client factory
new 2cea9131b [ISSUE #3949] forward message to dlq
new caaadca11 [ISSUE #3949] Improve readability.
new 3036cf421 [ISSUE #3949] Add className in createChannel
new 2824c686d [ISSUE #3949] Refector GrpcBaseTest
new 4c8283c95 [ISSUE #3949] can create transactionId when orgTransactionId is empty
new 04bdba442 [ISSUE #3949] For passing check style.
new b8b753ba9 [ISSUE #3949] Add Ack in LocalGrpcTest
new 15d181cd7 [ISSUE #3949] Support acl
new 76cf9dbdc [ISSUE #3949] For passing check style.
new 36b1e9fa2 [ISSUE #3949] Move common package, using adapter.
new a613f6c4f [ISSUE #3949] add test cases
new 79fcc9aea [ISSUE #3949] add test cases
new 528850151 [ISSUE #3949] Do some refactor work.
new 29084f87d [ISSUE #3949] Sort code for rebase
new 1976cc44c [ISSUE #3949] use log instead of LOGGER & pass unit tests.
new e91ccf0bd [ISSUE #3949] Do some refactoring work.
new ff3117f32 [ISSUE #3949] Do some refactoring work.
new 9cf17ebe4 [ISSUE #3949] Do some refactoring work.
new d6795c4a4 [ISSUE #3949] add v2 dependency
new c1d26c8b1 [ISSUE #3949] Import compatible rocketmq-proto.
new 7257add69 [ISSUE #3949] test cases
new 0bdd9224f [ISSUE #3949] code refactor
new d051fe9d7 [ISSUE #3949] code refactor
new 041bce0d4 [ISSUE #3949] Do refactor some code for readability.
new e4110ae7f [ISSUE #3949] v2 support
new 72d2581cf [ISSUE #3949] v2 support
new f0edf9964 [ISSUE #3949] Support v2 for LocalGrpcService
new 62c14bfdb [ISSUE #3949] Add telemetry
new 53fd599d8 [ISSUE #3949] Refector package structure
new e5466e2b6 [ISSUE #3949] Support v2
new 4b4cedc98 [ISSUE #3949] Support v2
new 2da929357 [ISSUE #3949] Refector by code review
new bc7fbfd46 [ISSUE #3949] Fix buildHeartbeatData
new f255f1bc3 [ISSUE #3949] Fix v2 endpoint for protocol
new 46ace3538 [ISSUE #3949] v2 support
new 74cac24c6 [ISSUE #3949] v2 test cases
new 1060caec5 [ISSUE #3949] Refector telemetry command
new 7fd29b43d [ISSUE #3949] Do refactor some code for readability.
new 5a58f2cb1 [ISSUE #3949] v2 test cases
new 58241f374 [ISSUE #3949] v2 test cases
new 78862bcd6 [ISSUE #3949] v2 test cases
new 2a240b7fc [ISSUE #3949] Add super.onMessage in AuthenticationInterceptor
new 41a976693 [ISSUE #3949] v2 test cases
new c7b81c13c [ISSUE #3949] Add integration test
new 35f06a4fd [ISSUE #3949] v2 client manager
new fc492d31d [ISSUE #3949] Add annotation and unit test
new 4db626bdb [ISSUE #3949] v2 support
new f93f2a3ad [ISSUE #3949] v2 support
new 2c53e88f6 [ISSUE #3949] v2 support
new af93b9745 [ISSUE #3949] v2 test cases
new 9b8e49bc8 [ISSUE #3949] v2 support
new 8caa00cdc [ISSUE #3949] use the right exception.
new 289b36d83 [ISSUE #3949] v2 support
new 69e5ef245 [ISSUE #3949] v2 support
new 149a4358d [ISSUE #3949] v2 support
new d43f6f434 [ISSUE #3949] Support batch ack
new 051fcb87d [ISSUE #3949] Support v2 protocol
new edab18a32 [ISSUE #3949] v2 support
new 3717c1634 [ISSUE #3949] v2 support
new f36fc44a3 [ISSUE #3949] v2 test cases
new 6b877b5bd [ISSUE #3949] v2 test cases
new 9baa00707 [ISSUE #3949] Fix request mapping
new a081ef4b2 [ISSUE #3949] v2 support
new c2059179e [ISSUE #3949] v2 support
new b8c3cbcc6 [ISSUE #3949] v2 support
new 34749eafe [ISSUE #3949] v2 support
new 1cc1d1043 [ISSUE #3949] v2 support
new c08fee78a [ISSUE #3949] do the code refactoring work for readability.
new 25cea8725 [ISSUE #3949] v2 support
new 8c41ccb0c [ISSUE #3949] v2 support
new c2fd34872 [ISSUE #3949] v2 support
new 862e77aef [ISSUE #3949] v2 support
new 7ce66f179 [ISSUE #3949] v2 support
new 21e436b8a [ISSUE #3949] v2 support
new 9c9600d51 [ISSUE #3949] v2 support
new 1667fb81f [ISSUE #3949] v2 support
new 03a10d560 [ISSUE #3949] Add local/RouteService
new fa2662713 [ISSUE #3949] v2 support
new b94dcd0a6 [ISSUE #3949] fix to fit checkStyle.
new de94a7065 [ISSUE #3949] v2 support
new f36f3c799 [ISSUE #3949] v2 support
new b47944321 [ISSUE #3949] Do refector and Fix unit test
new 6739a0510 [ISSUE #3949] Fix pop ResponseCode.POLLING_TIMEOUT
new 36347554c [ISSUE #3949] Remove unused variables
new f41b7eae6 [ISSUE #3949] Fix ChannelManager
new e65ff135b [ISSUE #3949] Remove v1 package
new 24467eabc [ISSUE #3949] Fetch Endpoints from request
new 9f090e245 [ISSUE #3949] v2 support
new 8dc4d516d [ISSUE #3949] v2 support
new 24742fbba [ISSUE #3949] v2 support
new 4cc05ebf1 [ISSUE #3949] Remove v1 package
new 9b88806a8 [ISSUE #3949] Remove unused finally
new 002164770 [ISSUE #3949] v2 support
new 30aa97317 [ISSUE #3949] Pass checkstyle
new afcade74c [ISSUE #3949] v2 support
new b7fa178d8 [ISSUE #3949] Fix unit test
new caeb5c175 [ISSUE #3949] Add integration testing
new 86284b4e1 [ISSUE #3949] Modify default configuration location
new 2a5391881 [ISSUE #3949] Add deploy guide
new 78aaf3b19 [ISSUE #3949] Format and clean code
new 6d57eef4c [ISSUE #3949] Add unit test
new 3ede21afb [ISSUE #3949] v2 support
new 2d594814b [ISSUE #3949] allow to config interceptor during building steps.
new d08dfce4f [ISSUE #3949] allow to add user-defined gRPC Server interceptors.
new 67d749b56 [ISSUE #3949] v2 support
new c6d6853ec [ISSUE #3949] Move parse and build method to PlainAccessResource
new 3c09e96cf [ISSUE #3949] Abstract PlainPermissionChecker
new 4882427b4 [ISSUE #3949] for check style and test case
new 98ada9886 [ISSUE #3949] Rename grpc IT
new 26b209867 [ISSUE #3949] Adapt for authorization
new 56c393f00 [ISSUE #3949] AddHeader in AuthenticationInterceptor
new 835714666 [ISSUE #3949] Reserve time for longpolling
new 7c77f4c32 [ISSUE #3949] AddHeader in AuthenticationInterceptor
new 74fedcbfa [ISSUE #3949] Add PermissionChecker
new d6720b568 [ISSUE #3949] Interceptor
new e549a67be refactor: [ISSUE #3949] v2 support
new 48a46f0f8 refactor: [ISSUE #3949] v2 support
new f91a4c0ee Rename ProxyOutService to ProxyRelayService
new c04c3185e Rename ProxyOutResult to ProxyRelayResult
new 1451bf555 [ISSUE #3949] v2 support
new fc1b26706 Add ServiceManagerFactory
new 418ced880 [ISSUE #3949] improve readability.
new 7c322c8ab [ISSUE #3949] support topic message type
new cfc6217c9 [ISSUE #3949] Remove unused class
new 172d610dc [ISSUE #3949] Add enableTopicMessageTypeCheck
new 966672ab2 [ISSUE #3949] Add MetadataService
new 9fe1bbc4d [ISSUE #3949] Fix configuration
new 20e9bdd3e [ISSUE #3949] v2 support
new 95b8105ff [ISSUE #3949] support config retryPolicy and consumeMessageOrderly in subscriptionGroupConfig
new bb5e55df1 [ISSUE #3949] add shutdown in ClusterMetadataService
new 610ab04ec [ISSUE #3949] add test cases
new 4ee1a9de7 [ISSUE #3949] improve readability.
new bc86a2ea9 [ISSUE #3949] change sendResult to list of sendResult; return MULTIPLE_RESULTS when has multiple response code
new 0b34b0add [ISSUE #3949] Add LocalProxyRelayService implementation
new 0ad9b3adb [ISSUE #3949] Remove backup code
new f334ca18d [ISSUE #3949] Fix batch sendMessageAsync
new 1a8c54bf4 [ISSUE #3949] Add sendMessage in LocalMessageService
new f87cc20d3 [ISSUE #3949] Remove nextVisibleTime in ReceiptHandle
new 41e5cdafe [ISSUE #3949] Complete LocalMessageService
new dfacfe607 [ISSUE #3949] Update LocalMessageService unit test
new a45b040fb [ISSUE #3949] add test cases
new 2fe29957c [ISSUE #3949] for checkstyle
new 1fa561cb9 [ISSUE #3949] Add TopicMessageTypeValidator
new aa313e96f [ISSUE #3949] Optimize enableACL configuration
new cc827021c [ISSUE #3949] add test cases
new 8bb6af15e [ISSUE #3949] Use MessageExt property to get TopicMessageType
new 8199c6d7b [ISSUE #3949] Complete processConsumeMessageDirectly and refector
new 908f977e7 [ISSUE #3949] Add unit test for ProducerProcessor
new 7647caf90 [ISSUE #3949] merge GrpcContextConstants into ContextVariable
new d44949f90 [ISSUE #3949] add test cases
new 989bd3ae5 [ISSUE #3949] fix test cases
new f040e167d [ISSUE #3949] Support TopicMessageType
new bd5fcf8f0 [ISSUE #3949] Remove unused method in TransactionId
new ca6c531d6 [ISSUE #3949] Remove unused code in SendMessageActivity
new 675b6c923 [ISSUE #3949] Add LocalProxyRelayService unit test
new ad5dc3fd4 [ISSUE #3949] add QueueSelector test cases
new 31a50fe83 [ISSUE #3949] Add unit test for ClientActivity
new d741618c0 [ISSUE #3949] Remove unused code in GrpcConverter
new e7bb6d7ee [ISSUE #3949] Add GrpcConverterTest
new 7fbe6e26e [ISSUE #3949] Add stack info when internal error
new 76c4fe784 [ISSUE #3949] assert Status when IT
new e54dad0eb [ISSUE #3949] Debug travis ci
new a2e50fbd0 [ISSUE #3949] Refine test process to solve IntegrationTest issue
new 9e1f2f99c [ISSUE #3949] Change topicCreateTime to 60
new 66ce5e539 Revert "[ISSUE #3949] Debug travis ci"
new 3bbca727a [ISSUE #3949] Remove unused method
new 36a6e3c58 Revert "[ISSUE #3949] Change topicCreateTime to 60"
new e9948ddfe [ISSUE #3949] Fix testTransactionCheckThenCommit
new 74366de8d [ISSUE #3949] Add FixMethodOrder for gRPC IT
new a59a8ad04 [ISSUE #3949] send heartbeat int transactionIT
new ade67ba81 [ISSUE #3949] Add GrpcMessagingApplicationTest
new 3685fdaae [ISSUE #3949] Refector AuthenticationInterceptor
new 74b808426 [ISSUE #3949] change toString to toStringHelper
new e21c5c06b [ISSUE #3949] setDeliveryTimestamp when complete ReceiveMessageResponse
new e3658d8a4 [ISSUE #3949] change toString to toStringHelper
new 3bac7de04 [ISSUE #3949] Add error handle when telemetry
new 405f5aad8 [ISSUE #3949] add log when write rejected response
new 73618554f [ISSUE #3949] for code style
new e52efc4ac [ISSUE #3949] not decompress body in proxy
new 64b58a54b support disableNettyWorkerGroup in NettyClientConfig
new 689c1f392 [ISSUE #3949] Refector send process
new 2ede51068 [ISSUE #3949] Support autoRenew
new e5430c562 [ISSUE #3949] Add build method for ProxyTopicRouteData
new c3059933e [ISSUE #3949] Update maven-checkstyle-plugin version
new 67f92fbdf [ISSUE #3949] Add getConsumerGroupInfo
new 0a017719c [ISSUE #3949] Add topic and queueId for MessageReceiptHandle
new 042febd9f [ISSUE #3949] Refector ReceiptHandleGroup
new eeccd9932 [ISSUE #3949] Add port for GrpcServerBuilder
new 404ee7e85 [ISSUE #3949] Add port for GrpcServerBuilder
new 20d649555 [ISSUE #3949] rename getProxyOutService to getProxyRelayService
new 33f422a20 [ISSUE #3949] Add method for MessagingProcessor and MessageService
new 03d2f9b4c [ISSUE #3949] Rename to AddressableMessageQueue
new 55bf26f2d [ISSUE #4384] Remove TimeUnit in nextDelayDuration
new 3cabbb050 [ISSUE #3949] Add offset related rpc
new b33915a4e [ISSUE #3949] add selectNextOne in MessageQueueSelector
new a465e2b72 [ISSUE #3949] use clientID instead of channelKey in ReceiptHandleProcessor
new 830e4fced [ISSUE #3949] Add CLIENT_REGISTER
new 618459d21 [ISSUE #3949] use proxyContext directly in activity
new 15f999cd8 [ISSUE #3949] pass context in rejectedExecution
new ebc21bb43 [ISSUE #3949] Add invoke and invokeOneway
new 2a089ffd3 [ISSUE #3906] Mark stream-related request by RequestType
new b869dd111 [ISSUE #3906] Add extFields to AclClientRPCHook.parseRequestContent
new 0eb4101af [ISSUE #3906] Add unit test
new 4db5fdf1d [ISSUE #3949] add header directly in validate
new cf742cac0 [ISSUE #3949] change ReceiptHandleGroup to msgID mapping
new f54f09d11 [ISSUE #3949] return removed handle when removeReceiptHandle
new 40818f677 [ISSUE #3949] set action in ProxyContext; add createForInner support
new e3296b8d2 [ISSUE #3949] Fill the field in the settings by MetricCollectorMode
new 374b0686a [ISSUE #3949] Add README
new d2b02ae8c [ISSUE #3949] change some parameters to protected
new ffa5a2d61 [ISSUE #3949] return port as grpc serverPort
new 8e70dc2ce [ISSUE #3949] Add exclude README
new af033c9aa [ISSUE #3949] Fix unit test
new 39750ec23 try to fix StaticTopicIT
new 947ffe4b9 [ISSUE #3949] Fix npe
new 04a256bd3 [ISSUE #3949] not to encode data in transactionId; save transaction data in mem
new eb380d9b4 [ISSUE #3949] isolate transactionId by producerGroup
new 496162061 [ISSUE #3949] parameter validate
new 461151c6f [ISSUE #3949] set born host when send and recv message
new 9d211f921 [ISSUE #3949] change default transactionCheckImmunityTime config
new 681608f66 [ISSUE #3949] change response code
new 5592cab67 [ISSUE #3949] report error info in end transaction
new fddac7892 [ISSUE #3949] change to use ConcurrentHashMap
new 0ff2c2fb6 [ISSUE #3949] for checkstyle
new 161dcdc3e [ISSUE #3949] add consume message orderly IT
new b117d697c [ISSUE #3949] config renewMaxTimeMillis
new 39e0a706c [ISSUE #3949] validate parameters
new fd0973ebd [ISSUE #3949] bug fix for receipt handle renew
new cb42639c5 [ISSUE #3949] validate consumer group in telemetry command
new 27c4ff948 [ISSUE #3949] fix cannot remove handle after renew
new ddaf054d6 [ISSUE #3949] add client version to proxy context.
new 3fa441611 [ISSUE #3949] use singleton for ResponseBuilder; check channel in recv and use handle saved in ack for autoRenew
new 87baf6da1 [ISSUE #3949] use singleton for GrpcConverter and ResponseWriter
new fe2e23a3f [ISSUE #3949] add producer and consumer to manager in telemetryCommand
new 9d4a13686 [ISSUE #3949] for checkstyle
new e6272b8e2 [ISSUE #3949] parse client version for grpc clients.
new e908d7c8d [ISSUE #3949] parse client version for grpc clients.
new cc996007c [ISSUE #3949] add PROPERTY_BORN_HOST into STRING_HASH_SET
new afb89da58 [ISSUE #3949] set maxAttempts to retryMaxTimes + 1
new e5124e40a [ISSUE #3949] fix test cases
new 6b45c9963 [ISSUE #3949] use SendMessageRequestHeaderV2
new 36caedd10 [ISSUE #3949] change defaultTransactionCheckImmunityTimeInSecond to 30
new 4749dbc0c [ISSUE #3949] Fix LocalMessageService
new 4f09b1eea [ISSUE #3949] Add addResourceAndPerm method
new 69d58d9ec [ISSUE #3949] Add permission for TelemetryCommand
new 5fb094a2c [ISSUE #3949] config transactionDataExpireMillis and transactionDataMaxNum
new c6918ea20 Add GrpcClientSettingsManager#mergeMetric
new be02f46b5 Adapt with the latest protocol
new b6a70e298 [ISSUE #3949] add parameter validator
new 6634a6a03 [ISSUE #3949] fix test cases
new baa36b4ec pass compile
new 72343c9f0 pass compile
new 5d10401ab Remove annotation
new fc39bd6dc [ISSUE #3949] Refine README
new 9fbaced20 Merge branch 'develop' into feature/grpc-develop-v2
new 67517545b fix pom.xml
new 1a542d945 add rmq-proxy.json to license ignore
new ef718d222 [ISSUE #3949] parameter validate
new 94153b031 [ISSUE #3949] Check handleGroup
new 9f9f9ed22 [ISSUE #3949] ignore exception for parsing grpc client version.
new 657d5edfb [ISSUE #3949] set delay level for message; use byte to calculate property size
new 9a0481c0b Merge branch 'feature/grpc-develop-v2' of github.com:drpmma/rocketmq into feature/grpc-develop-v2
new f88df48ba [ISSUE #3949] Set topic for LocalMessageService
new 6bcda57b3 [ISSUE #3949] Remove unused variables
new 77df4ce10 [ISSUE #3949] doc
new 852e9545d [ISSUE #3949] Add updateSubscription for registerConsumer
new 094a78d01 [ISSUE #3949] fix unit test
new 973359f2e [ISSUE #3949] Update rocketmq-proto to 2.0.0
new f51f9f657 Merge branch 'develop' into feature/grpc-develop-v2
new a483f2c14 Fix unit test conflict
new e6b4e15eb Merge pull request #4225 from drpmma/feature/grpc-develop-v2
The 7130 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.licenserc.yaml | 2 +
acl/pom.xml | 8 +
.../org/apache/rocketmq/acl/AccessValidator.java | 11 +-
.../org/apache/rocketmq/acl/PermissionChecker.java | 17 +-
.../rocketmq/acl/common/AuthenticationHeader.java | 236 ++++++
.../rocketmq/acl/common/AuthorizationHeader.java | 121 +++
.../rocketmq/acl/plain/PlainAccessResource.java | 230 ++++++
.../rocketmq/acl/plain/PlainAccessValidator.java | 133 +---
.../rocketmq/acl/plain/PlainPermissionChecker.java | 65 ++
.../rocketmq/acl/plain/PlainPermissionManager.java | 57 +-
.../apache/rocketmq/broker/BrokerController.java | 22 +-
.../rocketmq/broker/client/ConsumerGroupEvent.java | 10 +-
.../rocketmq/broker/client/ConsumerGroupInfo.java | 9 +-
.../rocketmq/broker/client/ConsumerManager.java | 63 +-
.../client/DefaultConsumerIdsChangeListener.java | 3 +
...GroupEvent.java => ProducerChangeListener.java} | 20 +-
...umerGroupEvent.java => ProducerGroupEvent.java} | 15 +-
.../rocketmq/broker/client/ProducerManager.java | 41 +-
.../processor/AbstractSendMessageProcessor.java | 115 +--
.../processor/ChangeInvisibleTimeProcessor.java | 1 +
.../broker/processor/PopMessageProcessor.java | 13 +-
.../TransactionalMessageCheckService.java | 2 +-
.../broker/client/ConsumerManagerScannerTest.java | 146 ++++
.../broker/client/ProducerManagerTest.java | 53 +-
.../broker/processor/PopMessageProcessorTest.java | 10 -
.../org/apache/rocketmq/client/ClientConfig.java | 25 +
.../client/exception/MQClientException.java | 7 +
.../rocketmq/client/impl/MQClientAPIImpl.java | 25 +-
.../client/impl/consumer/PullAPIWrapper.java | 7 +-
common/pom.xml | 9 +
.../rocketmq/common/constant/LoggerName.java | 2 +
.../rocketmq/common/consumer/ReceiptHandle.java | 232 ++++++
.../rocketmq/common/message/MessageBatch.java | 2 +-
.../rocketmq/common/message/MessageConst.java | 5 +
.../protocol/header/AckMessageRequestHeader.java | 9 +-
.../header/ChangeInvisibleTimeRequestHeader.java | 11 +
.../header/CheckTransactionStateRequestHeader.java | 12 +
.../header/CloneGroupOffsetRequestHeader.java | 11 +
.../ConsumeMessageDirectlyResultRequestHeader.java | 14 +
.../header/ConsumerSendMsgBackRequestHeader.java | 12 +-
.../header/CreateAccessConfigRequestHeader.java | 15 +
.../protocol/header/CreateTopicRequestHeader.java | 17 +
.../header/EndTransactionRequestHeader.java | 19 +-
.../header/GetConsumeStatsRequestHeader.java | 9 +
.../GetConsumerListByGroupRequestHeader.java | 8 +
.../GetConsumerRunningInfoRequestHeader.java | 10 +
.../header/GetConsumerStatusRequestHeader.java | 10 +
.../protocol/header/GetMaxOffsetRequestHeader.java | 10 +
.../protocol/header/GetMinOffsetRequestHeader.java | 9 +
.../protocol/header/PopMessageRequestHeader.java | 18 +
.../protocol/header/PullMessageRequestHeader.java | 19 +
.../protocol/header/SearchOffsetRequestHeader.java | 9 +
.../protocol/header/SendMessageRequestHeader.java | 119 +++
.../header/SendMessageRequestHeaderV2.java | 20 +
.../header/UpdateConsumerOffsetRequestHeader.java | 11 +
.../common/subscription/CustomizedRetryPolicy.java | 7 +
.../subscription/ExponentialRetryPolicy.java | 12 +-
.../rocketmq/common/thread/ThreadPoolMonitor.java | 131 ++++
.../ThreadPoolQueueSizeMonitor.java} | 29 +-
.../common/thread/ThreadPoolStatusMonitor.java | 26 +-
.../rocketmq/common/thread/ThreadPoolWrapper.java | 120 +++
.../apache/rocketmq/common/utils/BinaryUtil.java | 46 ++
distribution/bin/mqproxy | 45 ++
distribution/bin/mqproxy.cmd | 23 +
distribution/bin/mqshutdown | 16 +-
distribution/conf/logback_proxy.xml | 420 ++++++++++
distribution/conf/rmq-proxy.json | 3 +
distribution/pom.xml | 4 +
docs/en/README.md | 3 +
docs/en/images/rocketmq_proxy_cluster_mode.png | Bin 0 -> 28027 bytes
docs/en/images/rocketmq_proxy_local_mode.png | Bin 0 -> 22362 bytes
docs/en/proxy/deploy_guide.md | 37 +
pom.xml | 57 +-
proxy/README.md | 60 ++
proxy/pom.xml | 89 +++
.../java/org/apache/rocketmq/proxy/ProxyMode.java | 57 ++
.../org/apache/rocketmq/proxy/ProxyStartup.java | 173 +++++
.../rocketmq/proxy/common/AbstractCacheLoader.java | 54 ++
.../proxy/common/AbstractStartAndShutdown.java | 72 ++
.../org/apache/rocketmq/proxy/common/Address.java | 71 ++
.../rocketmq/proxy/common/ContextVariable.java | 23 +-
.../proxy/common/MessageReceiptHandle.java | 131 ++++
.../apache/rocketmq/proxy/common/ProxyContext.java | 115 +++
.../rocketmq/proxy/common/ProxyException.java | 31 +-
.../rocketmq/proxy/common/ProxyExceptionCode.java | 23 +-
.../rocketmq/proxy/common/ReceiptHandleGroup.java | 76 ++
.../org/apache/rocketmq/proxy/common/Shutdown.java | 17 +-
.../org/apache/rocketmq/proxy/common/Start.java | 17 +-
.../rocketmq/proxy/common/StartAndShutdown.java | 16 +-
.../proxy/common/utils/ExceptionUtils.java | 45 ++
.../rocketmq/proxy/common/utils/FilterUtils.java | 31 +-
.../rocketmq/proxy/common/utils/FutureUtils.java | 39 +-
.../rocketmq/proxy/common/utils/ProxyUtils.java | 19 +-
.../apache/rocketmq/proxy/config/ConfigFile.java | 18 +-
.../rocketmq/proxy/config/Configuration.java | 67 ++
.../proxy/config/ConfigurationManager.java | 48 ++
.../rocketmq/proxy/config/MetricCollectorMode.java | 35 +-
.../apache/rocketmq/proxy/config/ProxyConfig.java | 858 +++++++++++++++++++++
.../org/apache/rocketmq/proxy/grpc/GrpcServer.java | 48 ++
.../rocketmq/proxy/grpc/GrpcServerBuilder.java | 157 ++++
.../interceptor/AuthenticationInterceptor.java | 90 +++
.../proxy/grpc/interceptor/ContextInterceptor.java | 31 +-
.../interceptor/GlobalExceptionInterceptor.java | 128 +++
.../proxy/grpc/interceptor/HeaderInterceptor.java | 58 ++
.../grpc/interceptor/InterceptorConstants.java | 70 ++
.../proxy/grpc/interceptor/RequestMapping.java | 57 ++
.../proxy/grpc/v2/AbstractMessingActivity.java | 60 ++
.../proxy/grpc/v2/DefaultGrpcMessingActivity.java | 156 ++++
.../proxy/grpc/v2/GrpcMessagingApplication.java | 467 +++++++++++
.../proxy/grpc/v2/GrpcMessingActivity.java | 73 ++
.../proxy/grpc/v2/channel/GrpcChannelManager.java | 147 ++++
.../proxy/grpc/v2/channel/GrpcClientChannel.java | 195 +++++
.../proxy/grpc/v2/client/ClientActivity.java | 404 ++++++++++
.../grpc/v2/common/GrpcClientSettingsManager.java | 204 +++++
.../proxy/grpc/v2/common/GrpcConverter.java | 249 ++++++
.../proxy/grpc/v2/common/GrpcProxyException.java | 68 ++
.../proxy/grpc/v2/common/GrpcValidator.java | 130 ++++
.../proxy/grpc/v2/common/ResponseBuilder.java | 113 +++
.../proxy/grpc/v2/common/ResponseWriter.java | 80 ++
.../proxy/grpc/v2/consumer/AckMessageActivity.java | 146 ++++
.../consumer/ChangeInvisibleDurationActivity.java | 88 +++
.../v2/consumer/PopMessageResultFilterImpl.java | 46 ++
.../grpc/v2/consumer/ReceiveMessageActivity.java | 182 +++++
.../ReceiveMessageResponseStreamWriter.java | 160 ++++
.../v2/producer/ForwardMessageToDLQActivity.java | 65 ++
.../grpc/v2/producer/SendMessageActivity.java | 383 +++++++++
.../proxy/grpc/v2/route/RouteActivity.java | 252 ++++++
.../v2/transaction/EndTransactionActivity.java | 78 ++
.../proxy/processor/AbstractProcessor.java | 60 ++
.../rocketmq/proxy/processor/ClientProcessor.java | 111 +++
.../proxy/processor/ConsumerProcessor.java | 418 ++++++++++
.../proxy/processor/DefaultMessagingProcessor.java | 282 +++++++
.../proxy/processor/MessagingProcessor.java | 293 +++++++
.../proxy/processor/PopMessageResultFilter.java | 28 +-
.../proxy/processor/ProducerProcessor.java | 203 +++++
.../rocketmq/proxy/processor/QueueSelector.java | 21 +-
.../proxy/processor/ReceiptHandleProcessor.java | 261 +++++++
.../proxy/processor/TransactionProcessor.java | 75 ++
.../proxy/processor/TransactionStatus.java | 20 +-
.../DefaultTopicMessageTypeValidator.java | 26 +-
.../validator/TopicMessageTypeValidator.java | 21 +-
.../proxy/service/ClusterServiceManager.java | 179 +++++
.../proxy/service/LocalServiceManager.java | 128 +++
.../rocketmq/proxy/service/ServiceManager.java | 42 +
.../proxy/service/ServiceManagerFactory.java | 27 +-
.../proxy/service/channel/ChannelManager.java | 91 +++
.../proxy/service/channel/InvocationChannel.java | 80 ++
.../proxy/service/channel/InvocationContext.java | 34 +-
.../channel/InvocationContextInterface.java | 21 +-
.../proxy/service/channel/SimpleChannel.java | 197 +++++
.../channel/SimpleChannelHandlerContext.java | 246 ++++++
.../service/message/ClusterMessageService.java | 219 ++++++
.../proxy/service/message/LocalMessageService.java | 403 ++++++++++
.../service/message/LocalRemotingCommand.java | 37 +-
.../proxy/service/message/MessageService.java | 142 ++++
.../service/metadata/ClusterMetadataService.java | 169 ++++
.../service/metadata/LocalMetadataService.java | 45 ++
.../proxy/service/metadata/MetadataService.java | 23 +-
.../mqclient/DoNothingClientRemotingProcessor.java | 27 +-
.../proxy/service/mqclient/MQClientAPIExt.java | 620 +++++++++++++++
.../proxy/service/mqclient/MQClientAPIFactory.java | 113 +++
.../mqclient/ProxyClientRemotingProcessor.java | 67 ++
.../service/relay/AbstractProxyRelayService.java | 62 ++
.../service/relay/ClusterProxyRelayService.java | 50 ++
.../service/relay/LocalProxyRelayService.java | 88 +++
.../rocketmq/proxy/service/relay/ProxyChannel.java | 200 +++++
.../proxy/service/relay/ProxyRelayResult.java | 41 +-
.../proxy/service/relay/ProxyRelayService.java | 50 ++
.../rocketmq/proxy/service/relay/RelayData.java | 47 ++
.../service/route/AddressableMessageQueue.java | 82 ++
.../service/route/ClusterTopicRouteService.java | 73 ++
.../service/route/LocalTopicRouteService.java | 110 +++
.../proxy/service/route/MessageQueueSelector.java | 220 ++++++
.../proxy/service/route/MessageQueueView.java | 64 ++
.../proxy/service/route/ProxyTopicRouteData.java | 102 +++
.../proxy/service/route/TopicRouteHelper.java | 48 ++
.../proxy/service/route/TopicRouteService.java | 148 ++++
.../proxy/service/route/TopicRouteWrapper.java | 74 ++
.../transaction/AbstractTransactionService.java | 91 +++
.../transaction/ClusterTransactionService.java | 296 +++++++
.../transaction/EndTransactionRequestData.java | 46 ++
.../transaction/LocalTransactionService.java | 39 +-
.../proxy/service/transaction/TransactionData.java | 111 +++
.../transaction/TransactionDataManager.java | 163 ++++
.../service/transaction/TransactionService.java | 43 ++
.../proxy/common/utils/FilterUtilTest.java | 51 ++
.../proxy/config/ConfigurationManagerTest.java | 53 ++
.../proxy/config/InitConfigAndLoggerTest.java | 63 ++
.../proxy/config/MetricCollectorModeTest.java | 29 +-
.../proxy/grpc/v2/AbstractMessingActivityTest.java | 77 ++
.../rocketmq/proxy/grpc/v2/BaseActivityTest.java | 94 +++
.../grpc/v2/GrpcMessagingApplicationTest.java | 125 +++
.../proxy/grpc/v2/client/ClientActivityTest.java | 351 +++++++++
.../v2/common/GrpcClientSettingsManagerTest.java | 98 +++
.../proxy/grpc/v2/common/GrpcConverterTest.java | 41 +
.../grpc/v2/consumer/AckMessageActivityTest.java | 94 +++
.../ChangeInvisibleDurationActivityTest.java | 142 ++++
.../v2/consumer/ReceiveMessageActivityTest.java | 236 ++++++
.../ReceiveMessageResponseStreamWriterTest.java | 158 ++++
.../producer/ForwardMessageToDLQActivityTest.java | 64 ++
.../grpc/v2/producer/SendMessageActivityTest.java | 793 +++++++++++++++++++
.../proxy/grpc/v2/route/RouteActivityTest.java | 249 ++++++
.../v2/transaction/EndTransactionActivityTest.java | 100 +++
.../proxy/processor/BaseProcessorTest.java | 115 +++
.../proxy/processor/ConsumerProcessorTest.java | 176 +++++
.../proxy/processor/ProducerProcessorTest.java | 210 +++++
.../processor/ReceiptHandleProcessorTest.java | 198 +++++
.../proxy/processor/TransactionProcessorTest.java | 75 ++
.../rocketmq/proxy/service/BaseServiceTest.java | 83 ++
.../service/message/LocalMessageServiceTest.java | 451 +++++++++++
.../metadata/ClusterMetadataServiceTest.java | 70 ++
.../proxy/service/mqclient/MQClientAPIExtTest.java | 353 +++++++++
.../service/relay/LocalProxyRelayServiceTest.java | 102 +++
.../proxy/service/relay/ProxyChannelTest.java | 156 ++++
.../route/ClusterTopicRouteServiceTest.java | 70 ++
.../service/route/LocalTopicRouteServiceTest.java | 102 +++
.../service/route/MessageQueueSelectorTest.java | 84 ++
.../AbstractTransactionServiceTest.java | 138 ++++
.../transaction/ClusterTransactionServiceTest.java | 136 ++++
.../transaction/TransactionDataManagerTest.java | 138 ++++
.../resources/rmq-proxy-home}/conf/broker.conf | 0
.../rmq-proxy-home/conf/logback_proxy.xml | 420 ++++++++++
.../resources/rmq-proxy-home/conf/rmq-proxy.json | 3 +
.../rocketmq/remoting/netty/NettyClientConfig.java | 10 +-
.../remoting/netty/NettyRemotingClient.java | 4 +-
.../remoting/protocol/RemotingCommand.java | 2 +-
test/pom.xml | 21 +
.../rocketmq/test/util/MQAdminTestUtils.java | 19 +-
.../org/apache/rocketmq/test/base/BaseConf.java | 44 +-
.../rocketmq/test/base/IntegrationTestBase.java | 41 +-
.../base/dledger/DLedgerProduceAndConsumeIT.java | 2 +-
.../rocketmq/test/grpc/v2/ClusterGrpcIT.java | 114 +++
.../apache/rocketmq/test/grpc/v2/GrpcBaseIT.java | 805 +++++++++++++++++++
.../apache/rocketmq/test/grpc/v2/LocalGrpcIT.java | 102 +++
.../rocketmq/test/statictopic/StaticTopicIT.java | 2 +-
.../resources/rmq-proxy-home}/conf/broker.conf | 0
.../rmq-proxy-home/conf/logback_proxy.xml | 420 ++++++++++
.../resources/rmq-proxy-home/conf/rmq-proxy.json | 3 +
238 files changed, 23248 insertions(+), 854 deletions(-)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => acl/src/main/java/org/apache/rocketmq/acl/PermissionChecker.java (72%)
create mode 100644 acl/src/main/java/org/apache/rocketmq/acl/common/AuthenticationHeader.java
create mode 100644 acl/src/main/java/org/apache/rocketmq/acl/common/AuthorizationHeader.java
create mode 100644 acl/src/main/java/org/apache/rocketmq/acl/plain/PlainPermissionChecker.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/{ConsumerGroupEvent.java => ProducerChangeListener.java} (76%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/{ConsumerGroupEvent.java => ProducerGroupEvent.java} (79%)
create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/client/ConsumerManagerScannerTest.java
create mode 100644 common/src/main/java/org/apache/rocketmq/common/consumer/ReceiptHandle.java
create mode 100644 common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolMonitor.java
copy common/src/main/java/org/apache/rocketmq/common/{protocol/header/GetConsumerListByGroupRequestHeader.java => thread/ThreadPoolQueueSizeMonitor.java} (56%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolStatusMonitor.java (72%)
create mode 100644 common/src/main/java/org/apache/rocketmq/common/thread/ThreadPoolWrapper.java
create mode 100644 common/src/main/java/org/apache/rocketmq/common/utils/BinaryUtil.java
create mode 100644 distribution/bin/mqproxy
create mode 100644 distribution/bin/mqproxy.cmd
create mode 100644 distribution/conf/logback_proxy.xml
create mode 100644 distribution/conf/rmq-proxy.json
create mode 100644 docs/en/images/rocketmq_proxy_cluster_mode.png
create mode 100644 docs/en/images/rocketmq_proxy_local_mode.png
create mode 100644 docs/en/proxy/deploy_guide.md
create mode 100644 proxy/README.md
create mode 100644 proxy/pom.xml
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/ProxyMode.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/ProxyStartup.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractCacheLoader.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/AbstractStartAndShutdown.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/Address.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/ContextVariable.java (62%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/MessageReceiptHandle.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyContext.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyException.java (62%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/ProxyExceptionCode.java (72%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/ReceiptHandleGroup.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/Shutdown.java (72%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/Start.java (72%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/StartAndShutdown.java (72%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ExceptionUtils.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FilterUtils.java (54%)
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/FutureUtils.java (50%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/common/utils/ProxyUtils.java (72%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigFile.java (72%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/config/Configuration.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/config/ConfigurationManager.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/config/MetricCollectorMode.java (54%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/config/ProxyConfig.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServer.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/GrpcServerBuilder.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/AuthenticationInterceptor.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/ContextInterceptor.java (57%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/GlobalExceptionInterceptor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/HeaderInterceptor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/InterceptorConstants.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/interceptor/RequestMapping.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/DefaultGrpcMessingActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplication.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessingActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcChannelManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/channel/GrpcClientChannel.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverter.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcProxyException.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcValidator.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseBuilder.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/common/ResponseWriter.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ChangeInvisibleDurationActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/PopMessageResultFilterImpl.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriter.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivity.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/AbstractProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ClientProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ConsumerProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/DefaultMessagingProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/MessagingProcessor.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/processor/PopMessageResultFilter.java (62%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ProducerProcessor.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/processor/QueueSelector.java (69%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionProcessor.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/processor/TransactionStatus.java (72%)
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/DefaultTopicMessageTypeValidator.java (54%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/processor/validator/TopicMessageTypeValidator.java (65%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/ClusterServiceManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/LocalServiceManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManager.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/ServiceManagerFactory.java (53%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/ChannelManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationChannel.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContext.java (50%)
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/InvocationContextInterface.java (72%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannel.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/channel/SimpleChannelHandlerContext.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/ClusterMessageService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalMessageService.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumeStatsRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/message/LocalRemotingCommand.java (56%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/message/MessageService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/LocalMetadataService.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/metadata/MetadataService.java (69%)
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/DoNothingClientRemotingProcessor.java (57%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExt.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIFactory.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/mqclient/ProxyClientRemotingProcessor.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/AbstractProxyRelayService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ClusterProxyRelayService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/LocalProxyRelayService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyChannel.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetConsumerListByGroupRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayResult.java (54%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/ProxyRelayService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/relay/RelayData.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/AddressableMessageQueue.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelector.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/MessageQueueView.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/ProxyTopicRouteData.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteHelper.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/route/TopicRouteWrapper.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionService.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/EndTransactionRequestData.java
copy common/src/main/java/org/apache/rocketmq/common/protocol/header/GetMinOffsetRequestHeader.java => proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/LocalTransactionService.java (51%)
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionData.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManager.java
create mode 100644 proxy/src/main/java/org/apache/rocketmq/proxy/service/transaction/TransactionService.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/common/utils/FilterUtilTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/config/ConfigurationManagerTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/config/InitConfigAndLoggerTest.java
copy broker/src/main/java/org/apache/rocketmq/broker/client/ConsumerGroupEvent.java => proxy/src/test/java/org/apache/rocketmq/proxy/config/MetricCollectorModeTest.java (62%)
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/AbstractMessingActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/BaseActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/GrpcMessagingApplicationTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/client/ClientActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcClientSettingsManagerTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/common/GrpcConverterTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/consumer/AckMessageActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ChangeInvisibleDurationActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/consumer/ReceiveMessageResponseStreamWriterTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/ForwardMessageToDLQActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/producer/SendMessageActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/route/RouteActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/grpc/v2/transaction/EndTransactionActivityTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/processor/BaseProcessorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/processor/ConsumerProcessorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/processor/ProducerProcessorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/processor/ReceiptHandleProcessorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/processor/TransactionProcessorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/BaseServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/message/LocalMessageServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/metadata/ClusterMetadataServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/mqclient/MQClientAPIExtTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/relay/LocalProxyRelayServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/relay/ProxyChannelTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/route/ClusterTopicRouteServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/route/LocalTopicRouteServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/route/MessageQueueSelectorTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/transaction/AbstractTransactionServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/transaction/ClusterTransactionServiceTest.java
create mode 100644 proxy/src/test/java/org/apache/rocketmq/proxy/service/transaction/TransactionDataManagerTest.java
copy {distribution => proxy/src/test/resources/rmq-proxy-home}/conf/broker.conf (100%)
create mode 100644 proxy/src/test/resources/rmq-proxy-home/conf/logback_proxy.xml
create mode 100644 proxy/src/test/resources/rmq-proxy-home/conf/rmq-proxy.json
create mode 100644 test/src/test/java/org/apache/rocketmq/test/grpc/v2/ClusterGrpcIT.java
create mode 100644 test/src/test/java/org/apache/rocketmq/test/grpc/v2/GrpcBaseIT.java
create mode 100644 test/src/test/java/org/apache/rocketmq/test/grpc/v2/LocalGrpcIT.java
copy {distribution => test/src/test/resources/rmq-proxy-home}/conf/broker.conf (100%)
create mode 100644 test/src/test/resources/rmq-proxy-home/conf/logback_proxy.xml
create mode 100644 test/src/test/resources/rmq-proxy-home/conf/rmq-proxy.json