You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by ji...@apache.org on 2022/07/20 02:54:12 UTC
[rocketmq] branch 5.0.0-beta-dledger-controller updated (eb4e68464 -> dd09f2b78)
This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch 5.0.0-beta-dledger-controller
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from eb4e68464 [ISSUE #4626] Add CRC32 verification when saving checkpoint file (#4627)
add b136f9bb6 Bump commons-io from 2.6 to 2.7 (#4600)
add 74e1a60b3 [ISSUE #4597] Fix inaccurate judgement
add 8cb34fb7e Add unit test
add 29713cb22 Merge pull request #4586 from Oliverwqcwrw/develop-add-ut-20
add 225bc42f9 Fix the wrong format output of clusterlist command (#4608)
add 00da3e724 [ISSUE #4606] Build trace msgs for DefaultLitePullConsumer when poll is called
add 870e8e462 Fix issue 4617
add d9cec7f6b Merge pull request #4618 from Oliverwqcwrw/develop-same-addr-27
add c1b14b0dd Fix typo
add 0ba53e50b Merge pull request #4619 from Oliverwqcwrw/develop-fix-typo-27
add 3ee603a49 Try to make CI test more stable (#4616)
add ac6ccc544 [ISSUE #3905] Support bname in protocol
add d930cb96a [ISSUE #4624] Add plain_acl_bak.xml for reset at test case start. (#4625)
add edf2ee00a map null exception
add f751fc313 Merge pull request #4629 from fujian-zfj/develop-1
add cdb4bd94f [ISSUE #4167] Add unit test (ConsumerManagerTest) (#4633)
add 91d36fd54 Remove unnecessary ignore test
add 89cb8cce8 [ISSUE #4630] Fix RequestTask's stopRun field concurrency issues(#4631) (#4631)
add 8d203e847 [ISSUE #3949] Add rocketmq-proto dependency.
add 3134916c5 [ISSUE #3949] Initialize basic structure
add 57a549a95 [ISSUE #3949] Add interface for GrpcService
add dcfa88bca [ISSUE #3949] Init proxyStartup.
add 876f31c31 [ISSUE #3949] Add UT for configuration package.
add 763e874b2 [ISSUE #3949] can config bootstrap thread num; disable callbackExecutor and nettyWorkerGroup in NettyClientConfig
add ca3de6a31 [ISSUE #3949] add client for proxy in cluster mode
add 80b2f95d1 [ISSUE #3949] Support sendMessage in Local mode
add 4059688c7 [ISSUE #3949] Add HeaderInterceptor
add 38ab97cc3 [ISSUE #3949] Use CompletableFuture
add 6fcefe10e [ISSUE #3949] Add sendMessage in GrpcMessagingProcessor
add b7c9e97f2 [ISSUE #3949] Add UT for LocalGrpcService
add e319024fa [ISSUE #3949] Add logger config and rename GrpcService to GrpcForwardService.
add 23c14ff73 [ISSUE #3949] Add Base Initialization for test cases.
add 64f22d910 [ISSUE #3949] Add UT for clientManager.
add 8d924e9e6 [ISSUE #3949] refactor SelectableMessageQueue.
add 115030a80 [ISSUE #3949] Refector SimpleChannel
add 9e2dc9329 [ISSUE #3949] Add code in GrpcMessagingProcessor
add f5df79939 [ISSUE #3949] Add heartbeat in LocalGrpcService
add 85d4a368c [ISSUE #3949] Add Converter.buildPopMessageRequestHeader
add 0e5dee8b4 [ISSUE #3949] queryRoute, queryAssignment, sendMessage for cluster mode
add be512d574 [ISSUE #3949] refactor SelectableMessageQueue and do the merging work.
add 3b437435b [ISSUE #3949] do some renaming work.
add 6b985f766 [ISSUE #3949] Fix unit test
add 60868dafc [ISSUE #3949] Add receiveMessage
add 0cd8ff08e [ISSUE #3949] Remove consumerGroupInfo in PopMessageProcessor
add 19161001f [ISSUE #3949] Add IT
add 902f09c92 [ISSUE #3949] Fix codes for passing style checking.
add 540ccd741 [ISSUE #3949] add grpc channel impl
add db7ab9b61 [ISSUE #3949] Refector Channels
add 63211bdcf [ISSUE #3949] Do some renaming work.
add 5c6fccacc [ISSUE #3949] Do some renaming work.
add 77d7da51c [ISSUE #3949] Implement ack and nack
add f07904a70 [ISSUE #3949] Simplify Channels
add 42ee31ec4 [ISSUE #3949] Implement ForwardMessageToDeadLetterQueue
add 89e0727b7 [ISSUE #3949] receiveMessage for cluster mode; code refactor for queryRoute, queryAssignment, sendMessage
add c456ea788 [ISSUE #3949] Implement pollCommand
add 67440ebe2 [ISSUE #3949] pollCommand for cluster mode
add 5cbb01e37 [ISSUE #3949] Implement Local transaction module
add 10a7b3c9a [ISSUE #3949] ack, nack for cluster mode
add 1150aa994 [ISSUE #3949] pull message for cluster mode and code refactor
add fe96159a4 [ISSUE #3949] transaction support for cluster mode
add b425608b1 [ISSUE #3949] Refactor partition generation and add unit test.
add e44f29a64 [ISSUE #3949] forwardMsgToDLQ for cluster mode; add ProducerGroupOfflineListener
add 7f4b7bce2 [ISSUE #3949] Do refactor work for passing check style.
add d0ed25e93 [ISSUE #3949] Implement route in Local mode
add 806def231 [ISSUE #3949] Support PollCommand
add 153b2ddd4 [ISSUE #3949] Implement notifyClientTermination and changeInvisibleDuration
add 527a38cef [ISSUE #3949] Implement pull and stream
add 83e9d838d [ISSUE #3949] Do some refactoring for passing check style.
add afc2aeab6 [ISSUE #3949] Do some refactoring for readability.
add 5c8374c43 [ISSUE #3949] Add unit test
add 053c6437f [ISSUE #3949] Add DelayPolicy
add a96b21448 [ISSUE #3949] Improve readability.
add f9c3a5e49 [ISSUE #3949] Improve readability.
add 1dc5b7c41 [ISSUE #3949] Improve readability.
add 3f07761f6 [ISSUE #3949] ack msg when tag not match; refactor client factory
add 2cea9131b [ISSUE #3949] forward message to dlq
add caaadca11 [ISSUE #3949] Improve readability.
add 3036cf421 [ISSUE #3949] Add className in createChannel
add 2824c686d [ISSUE #3949] Refector GrpcBaseTest
add 4c8283c95 [ISSUE #3949] can create transactionId when orgTransactionId is empty
add 04bdba442 [ISSUE #3949] For passing check style.
add b8b753ba9 [ISSUE #3949] Add Ack in LocalGrpcTest
add 15d181cd7 [ISSUE #3949] Support acl
add 76cf9dbdc [ISSUE #3949] For passing check style.
add 36b1e9fa2 [ISSUE #3949] Move common package, using adapter.
add a613f6c4f [ISSUE #3949] add test cases
add 79fcc9aea [ISSUE #3949] add test cases
add 528850151 [ISSUE #3949] Do some refactor work.
add 29084f87d [ISSUE #3949] Sort code for rebase
add 1976cc44c [ISSUE #3949] use log instead of LOGGER & pass unit tests.
add e91ccf0bd [ISSUE #3949] Do some refactoring work.
add ff3117f32 [ISSUE #3949] Do some refactoring work.
add 9cf17ebe4 [ISSUE #3949] Do some refactoring work.
add d6795c4a4 [ISSUE #3949] add v2 dependency
add c1d26c8b1 [ISSUE #3949] Import compatible rocketmq-proto.
add 7257add69 [ISSUE #3949] test cases
add 0bdd9224f [ISSUE #3949] code refactor
add d051fe9d7 [ISSUE #3949] code refactor
add 041bce0d4 [ISSUE #3949] Do refactor some code for readability.
add e4110ae7f [ISSUE #3949] v2 support
add 72d2581cf [ISSUE #3949] v2 support
add f0edf9964 [ISSUE #3949] Support v2 for LocalGrpcService
add 62c14bfdb [ISSUE #3949] Add telemetry
add 53fd599d8 [ISSUE #3949] Refector package structure
add e5466e2b6 [ISSUE #3949] Support v2
add 4b4cedc98 [ISSUE #3949] Support v2
add 2da929357 [ISSUE #3949] Refector by code review
add bc7fbfd46 [ISSUE #3949] Fix buildHeartbeatData
add f255f1bc3 [ISSUE #3949] Fix v2 endpoint for protocol
add 46ace3538 [ISSUE #3949] v2 support
add 74cac24c6 [ISSUE #3949] v2 test cases
add 1060caec5 [ISSUE #3949] Refector telemetry command
add 7fd29b43d [ISSUE #3949] Do refactor some code for readability.
add 5a58f2cb1 [ISSUE #3949] v2 test cases
add 58241f374 [ISSUE #3949] v2 test cases
add 78862bcd6 [ISSUE #3949] v2 test cases
add 2a240b7fc [ISSUE #3949] Add super.onMessage in AuthenticationInterceptor
add 41a976693 [ISSUE #3949] v2 test cases
add c7b81c13c [ISSUE #3949] Add integration test
add 35f06a4fd [ISSUE #3949] v2 client manager
add fc492d31d [ISSUE #3949] Add annotation and unit test
add 4db626bdb [ISSUE #3949] v2 support
add f93f2a3ad [ISSUE #3949] v2 support
add 2c53e88f6 [ISSUE #3949] v2 support
add af93b9745 [ISSUE #3949] v2 test cases
add 9b8e49bc8 [ISSUE #3949] v2 support
add 8caa00cdc [ISSUE #3949] use the right exception.
add 289b36d83 [ISSUE #3949] v2 support
add 69e5ef245 [ISSUE #3949] v2 support
add 149a4358d [ISSUE #3949] v2 support
add d43f6f434 [ISSUE #3949] Support batch ack
add 051fcb87d [ISSUE #3949] Support v2 protocol
add edab18a32 [ISSUE #3949] v2 support
add 3717c1634 [ISSUE #3949] v2 support
add f36fc44a3 [ISSUE #3949] v2 test cases
add 6b877b5bd [ISSUE #3949] v2 test cases
add 9baa00707 [ISSUE #3949] Fix request mapping
add a081ef4b2 [ISSUE #3949] v2 support
add c2059179e [ISSUE #3949] v2 support
add b8c3cbcc6 [ISSUE #3949] v2 support
add 34749eafe [ISSUE #3949] v2 support
add 1cc1d1043 [ISSUE #3949] v2 support
add c08fee78a [ISSUE #3949] do the code refactoring work for readability.
add 25cea8725 [ISSUE #3949] v2 support
add 8c41ccb0c [ISSUE #3949] v2 support
add c2fd34872 [ISSUE #3949] v2 support
add 862e77aef [ISSUE #3949] v2 support
add 7ce66f179 [ISSUE #3949] v2 support
add 21e436b8a [ISSUE #3949] v2 support
add 9c9600d51 [ISSUE #3949] v2 support
add 1667fb81f [ISSUE #3949] v2 support
add 03a10d560 [ISSUE #3949] Add local/RouteService
add fa2662713 [ISSUE #3949] v2 support
add b94dcd0a6 [ISSUE #3949] fix to fit checkStyle.
add de94a7065 [ISSUE #3949] v2 support
add f36f3c799 [ISSUE #3949] v2 support
add b47944321 [ISSUE #3949] Do refector and Fix unit test
add 6739a0510 [ISSUE #3949] Fix pop ResponseCode.POLLING_TIMEOUT
add 36347554c [ISSUE #3949] Remove unused variables
add f41b7eae6 [ISSUE #3949] Fix ChannelManager
add e65ff135b [ISSUE #3949] Remove v1 package
add 24467eabc [ISSUE #3949] Fetch Endpoints from request
add 9f090e245 [ISSUE #3949] v2 support
add 8dc4d516d [ISSUE #3949] v2 support
add 24742fbba [ISSUE #3949] v2 support
add 4cc05ebf1 [ISSUE #3949] Remove v1 package
add 9b88806a8 [ISSUE #3949] Remove unused finally
add 002164770 [ISSUE #3949] v2 support
add 30aa97317 [ISSUE #3949] Pass checkstyle
add afcade74c [ISSUE #3949] v2 support
add b7fa178d8 [ISSUE #3949] Fix unit test
add caeb5c175 [ISSUE #3949] Add integration testing
add 86284b4e1 [ISSUE #3949] Modify default configuration location
add 2a5391881 [ISSUE #3949] Add deploy guide
add 78aaf3b19 [ISSUE #3949] Format and clean code
add 6d57eef4c [ISSUE #3949] Add unit test
add 3ede21afb [ISSUE #3949] v2 support
add 2d594814b [ISSUE #3949] allow to config interceptor during building steps.
add d08dfce4f [ISSUE #3949] allow to add user-defined gRPC Server interceptors.
add 67d749b56 [ISSUE #3949] v2 support
add c6d6853ec [ISSUE #3949] Move parse and build method to PlainAccessResource
add 3c09e96cf [ISSUE #3949] Abstract PlainPermissionChecker
add 4882427b4 [ISSUE #3949] for check style and test case
add 98ada9886 [ISSUE #3949] Rename grpc IT
add 26b209867 [ISSUE #3949] Adapt for authorization
add 56c393f00 [ISSUE #3949] AddHeader in AuthenticationInterceptor
add 835714666 [ISSUE #3949] Reserve time for longpolling
add 7c77f4c32 [ISSUE #3949] AddHeader in AuthenticationInterceptor
add 74fedcbfa [ISSUE #3949] Add PermissionChecker
add d6720b568 [ISSUE #3949] Interceptor
add e549a67be refactor: [ISSUE #3949] v2 support
add 48a46f0f8 refactor: [ISSUE #3949] v2 support
add f91a4c0ee Rename ProxyOutService to ProxyRelayService
add c04c3185e Rename ProxyOutResult to ProxyRelayResult
add 1451bf555 [ISSUE #3949] v2 support
add fc1b26706 Add ServiceManagerFactory
add 418ced880 [ISSUE #3949] improve readability.
add 7c322c8ab [ISSUE #3949] support topic message type
add cfc6217c9 [ISSUE #3949] Remove unused class
add 172d610dc [ISSUE #3949] Add enableTopicMessageTypeCheck
add 966672ab2 [ISSUE #3949] Add MetadataService
add 9fe1bbc4d [ISSUE #3949] Fix configuration
add 20e9bdd3e [ISSUE #3949] v2 support
add 95b8105ff [ISSUE #3949] support config retryPolicy and consumeMessageOrderly in subscriptionGroupConfig
add bb5e55df1 [ISSUE #3949] add shutdown in ClusterMetadataService
add 610ab04ec [ISSUE #3949] add test cases
add 4ee1a9de7 [ISSUE #3949] improve readability.
add bc86a2ea9 [ISSUE #3949] change sendResult to list of sendResult; return MULTIPLE_RESULTS when has multiple response code
add 0b34b0add [ISSUE #3949] Add LocalProxyRelayService implementation
add 0ad9b3adb [ISSUE #3949] Remove backup code
add f334ca18d [ISSUE #3949] Fix batch sendMessageAsync
add 1a8c54bf4 [ISSUE #3949] Add sendMessage in LocalMessageService
add f87cc20d3 [ISSUE #3949] Remove nextVisibleTime in ReceiptHandle
add 41e5cdafe [ISSUE #3949] Complete LocalMessageService
add dfacfe607 [ISSUE #3949] Update LocalMessageService unit test
add a45b040fb [ISSUE #3949] add test cases
add 2fe29957c [ISSUE #3949] for checkstyle
add 1fa561cb9 [ISSUE #3949] Add TopicMessageTypeValidator
add aa313e96f [ISSUE #3949] Optimize enableACL configuration
add cc827021c [ISSUE #3949] add test cases
add 8bb6af15e [ISSUE #3949] Use MessageExt property to get TopicMessageType
add 8199c6d7b [ISSUE #3949] Complete processConsumeMessageDirectly and refector
add 908f977e7 [ISSUE #3949] Add unit test for ProducerProcessor
add 7647caf90 [ISSUE #3949] merge GrpcContextConstants into ContextVariable
add d44949f90 [ISSUE #3949] add test cases
add 989bd3ae5 [ISSUE #3949] fix test cases
add f040e167d [ISSUE #3949] Support TopicMessageType
add bd5fcf8f0 [ISSUE #3949] Remove unused method in TransactionId
add ca6c531d6 [ISSUE #3949] Remove unused code in SendMessageActivity
add 675b6c923 [ISSUE #3949] Add LocalProxyRelayService unit test
add ad5dc3fd4 [ISSUE #3949] add QueueSelector test cases
add 31a50fe83 [ISSUE #3949] Add unit test for ClientActivity
add d741618c0 [ISSUE #3949] Remove unused code in GrpcConverter
add e7bb6d7ee [ISSUE #3949] Add GrpcConverterTest
add 7fbe6e26e [ISSUE #3949] Add stack info when internal error
add 76c4fe784 [ISSUE #3949] assert Status when IT
add e54dad0eb [ISSUE #3949] Debug travis ci
add a2e50fbd0 [ISSUE #3949] Refine test process to solve IntegrationTest issue
add 9e1f2f99c [ISSUE #3949] Change topicCreateTime to 60
add 66ce5e539 Revert "[ISSUE #3949] Debug travis ci"
add 3bbca727a [ISSUE #3949] Remove unused method
add 36a6e3c58 Revert "[ISSUE #3949] Change topicCreateTime to 60"
add e9948ddfe [ISSUE #3949] Fix testTransactionCheckThenCommit
add 74366de8d [ISSUE #3949] Add FixMethodOrder for gRPC IT
add a59a8ad04 [ISSUE #3949] send heartbeat int transactionIT
add ade67ba81 [ISSUE #3949] Add GrpcMessagingApplicationTest
add 3685fdaae [ISSUE #3949] Refector AuthenticationInterceptor
add 74b808426 [ISSUE #3949] change toString to toStringHelper
add e21c5c06b [ISSUE #3949] setDeliveryTimestamp when complete ReceiveMessageResponse
add e3658d8a4 [ISSUE #3949] change toString to toStringHelper
add 3bac7de04 [ISSUE #3949] Add error handle when telemetry
add 405f5aad8 [ISSUE #3949] add log when write rejected response
add 73618554f [ISSUE #3949] for code style
add e52efc4ac [ISSUE #3949] not decompress body in proxy
add 64b58a54b support disableNettyWorkerGroup in NettyClientConfig
add 689c1f392 [ISSUE #3949] Refector send process
add 2ede51068 [ISSUE #3949] Support autoRenew
add e5430c562 [ISSUE #3949] Add build method for ProxyTopicRouteData
add c3059933e [ISSUE #3949] Update maven-checkstyle-plugin version
add 67f92fbdf [ISSUE #3949] Add getConsumerGroupInfo
add 0a017719c [ISSUE #3949] Add topic and queueId for MessageReceiptHandle
add 042febd9f [ISSUE #3949] Refector ReceiptHandleGroup
add eeccd9932 [ISSUE #3949] Add port for GrpcServerBuilder
add 404ee7e85 [ISSUE #3949] Add port for GrpcServerBuilder
add 20d649555 [ISSUE #3949] rename getProxyOutService to getProxyRelayService
add 33f422a20 [ISSUE #3949] Add method for MessagingProcessor and MessageService
add 03d2f9b4c [ISSUE #3949] Rename to AddressableMessageQueue
add 55bf26f2d [ISSUE #4384] Remove TimeUnit in nextDelayDuration
add 3cabbb050 [ISSUE #3949] Add offset related rpc
add b33915a4e [ISSUE #3949] add selectNextOne in MessageQueueSelector
add a465e2b72 [ISSUE #3949] use clientID instead of channelKey in ReceiptHandleProcessor
add 830e4fced [ISSUE #3949] Add CLIENT_REGISTER
add 618459d21 [ISSUE #3949] use proxyContext directly in activity
add 15f999cd8 [ISSUE #3949] pass context in rejectedExecution
add ebc21bb43 [ISSUE #3949] Add invoke and invokeOneway
add 2a089ffd3 [ISSUE #3906] Mark stream-related request by RequestType
add b869dd111 [ISSUE #3906] Add extFields to AclClientRPCHook.parseRequestContent
add 0eb4101af [ISSUE #3906] Add unit test
add 4db5fdf1d [ISSUE #3949] add header directly in validate
add cf742cac0 [ISSUE #3949] change ReceiptHandleGroup to msgID mapping
add f54f09d11 [ISSUE #3949] return removed handle when removeReceiptHandle
add 40818f677 [ISSUE #3949] set action in ProxyContext; add createForInner support
add e3296b8d2 [ISSUE #3949] Fill the field in the settings by MetricCollectorMode
add 374b0686a [ISSUE #3949] Add README
add d2b02ae8c [ISSUE #3949] change some parameters to protected
add ffa5a2d61 [ISSUE #3949] return port as grpc serverPort
add 8e70dc2ce [ISSUE #3949] Add exclude README
add af033c9aa [ISSUE #3949] Fix unit test
add 39750ec23 try to fix StaticTopicIT
add 947ffe4b9 [ISSUE #3949] Fix npe
add 04a256bd3 [ISSUE #3949] not to encode data in transactionId; save transaction data in mem
add eb380d9b4 [ISSUE #3949] isolate transactionId by producerGroup
add 496162061 [ISSUE #3949] parameter validate
add 461151c6f [ISSUE #3949] set born host when send and recv message
add 9d211f921 [ISSUE #3949] change default transactionCheckImmunityTime config
add 681608f66 [ISSUE #3949] change response code
add 5592cab67 [ISSUE #3949] report error info in end transaction
add fddac7892 [ISSUE #3949] change to use ConcurrentHashMap
add 0ff2c2fb6 [ISSUE #3949] for checkstyle
add 161dcdc3e [ISSUE #3949] add consume message orderly IT
add b117d697c [ISSUE #3949] config renewMaxTimeMillis
add 39e0a706c [ISSUE #3949] validate parameters
add fd0973ebd [ISSUE #3949] bug fix for receipt handle renew
add cb42639c5 [ISSUE #3949] validate consumer group in telemetry command
add 27c4ff948 [ISSUE #3949] fix cannot remove handle after renew
add ddaf054d6 [ISSUE #3949] add client version to proxy context.
add 3fa441611 [ISSUE #3949] use singleton for ResponseBuilder; check channel in recv and use handle saved in ack for autoRenew
add 87baf6da1 [ISSUE #3949] use singleton for GrpcConverter and ResponseWriter
add fe2e23a3f [ISSUE #3949] add producer and consumer to manager in telemetryCommand
add 9d4a13686 [ISSUE #3949] for checkstyle
add e6272b8e2 [ISSUE #3949] parse client version for grpc clients.
add e908d7c8d [ISSUE #3949] parse client version for grpc clients.
add cc996007c [ISSUE #3949] add PROPERTY_BORN_HOST into STRING_HASH_SET
add afb89da58 [ISSUE #3949] set maxAttempts to retryMaxTimes + 1
add e5124e40a [ISSUE #3949] fix test cases
add 6b45c9963 [ISSUE #3949] use SendMessageRequestHeaderV2
add 36caedd10 [ISSUE #3949] change defaultTransactionCheckImmunityTimeInSecond to 30
add 4749dbc0c [ISSUE #3949] Fix LocalMessageService
add 4f09b1eea [ISSUE #3949] Add addResourceAndPerm method
add 69d58d9ec [ISSUE #3949] Add permission for TelemetryCommand
add 5fb094a2c [ISSUE #3949] config transactionDataExpireMillis and transactionDataMaxNum
add c6918ea20 Add GrpcClientSettingsManager#mergeMetric
add be02f46b5 Adapt with the latest protocol
add b6a70e298 [ISSUE #3949] add parameter validator
add 6634a6a03 [ISSUE #3949] fix test cases
add baa36b4ec pass compile
add 72343c9f0 pass compile
add 5d10401ab Remove annotation
add fc39bd6dc [ISSUE #3949] Refine README
add 9fbaced20 Merge branch 'develop' into feature/grpc-develop-v2
add 67517545b fix pom.xml
add 1a542d945 add rmq-proxy.json to license ignore
add ef718d222 [ISSUE #3949] parameter validate
add 94153b031 [ISSUE #3949] Check handleGroup
add 9f9f9ed22 [ISSUE #3949] ignore exception for parsing grpc client version.
add 657d5edfb [ISSUE #3949] set delay level for message; use byte to calculate property size
add 9a0481c0b Merge branch 'feature/grpc-develop-v2' of github.com:drpmma/rocketmq into feature/grpc-develop-v2
add f88df48ba [ISSUE #3949] Set topic for LocalMessageService
add 6bcda57b3 [ISSUE #3949] Remove unused variables
add 77df4ce10 [ISSUE #3949] doc
add 852e9545d [ISSUE #3949] Add updateSubscription for registerConsumer
add 094a78d01 [ISSUE #3949] fix unit test
add 973359f2e [ISSUE #3949] Update rocketmq-proto to 2.0.0
add f51f9f657 Merge branch 'develop' into feature/grpc-develop-v2
add a483f2c14 Fix unit test conflict
add e6b4e15eb Merge pull request #4225 from drpmma/feature/grpc-develop-v2
add dd09f2b78 Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller
No new revisions were added by this update.
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 +-
.../acl/plain/PlainAccessValidatorTest.java | 59 +-
.../acl/plain/PlainPermissionManagerTest.java | 25 +
.../conf/{plain_acl.yml => plain_acl_bak.yml} | 0
.../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 +-
.../rocketmq/broker/slave/SlaveSynchronize.java | 2 +-
.../TransactionalMessageCheckService.java | 2 +-
.../broker/client/ConsumerManagerScannerTest.java | 146 ++++
.../broker/client/ConsumerManagerTest.java | 155 ++++
.../broker/client/ProducerManagerTest.java | 53 +-
.../broker/processor/PopMessageProcessorTest.java | 10 -
.../org/apache/rocketmq/client/ClientConfig.java | 25 +
.../consumer/store/RemoteBrokerOffsetStore.java | 2 +
.../client/exception/MQClientException.java | 7 +
.../apache/rocketmq/client/impl/MQAdminImpl.java | 10 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 73 +-
.../impl/consumer/DefaultLitePullConsumerImpl.java | 24 +-
.../client/impl/consumer/PullAPIWrapper.java | 9 +-
.../trace/hook/SendMessageTraceHookImpl.java | 32 +-
.../rocketmq/client/impl/MQClientAPIImplTest.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 | 58 +-
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 +-
.../rocketmq/remoting/netty/RequestTask.java | 2 +-
.../remoting/protocol/RemotingCommand.java | 2 +-
.../org/apache/rocketmq/store/ConsumeQueue.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 | 12 +-
.../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/tools/admin/DefaultMQAdminExt.java | 1 +
.../tools/admin/DefaultMQAdminExtImpl.java | 8 +-
.../apache/rocketmq/tools/admin/MQAdminExt.java | 1 +
.../command/cluster/ClusterListSubCommand.java | 2 +-
.../command/queue/QueryConsumeQueueCommand.java | 3 +-
.../tools/admin/DefaultMQAdminExtTest.java | 33 +-
256 files changed, 23582 insertions(+), 949 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 acl/src/test/resources/conf/{plain_acl.yml => plain_acl_bak.yml} (100%)
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 broker/src/test/java/org/apache/rocketmq/broker/client/ConsumerManagerTest.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