opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-09-21 13:49:50 +08:00
Code Issues Packages Projects Releases Wiki Activity
2,347 Commits 73 Branches 40 Tags
0ad9b3adb19ae30ee293edbc922ac7ac72b76c9f
Commit Graph
171 Commits
Author SHA1 Message Date
zhouxiang 0ad9b3adb1 [ISSUE #3949] Remove backup code 2022-07-13 11:29:37 +08:00
zhouxiang 0b34b0add7 [ISSUE #3949] Add LocalProxyRelayService implementation 2022-07-13 11:29:37 +08:00
kaiyi.lk bc86a2ea9a [ISSUE #3949] change sendResult to list of sendResult; return MULTIPLE_RESULTS when has multiple response code 2022-07-13 11:29:37 +08:00
Jixiang.jjx 4ee1a9de76 [ISSUE #3949] improve readability. 2022-07-13 11:29:37 +08:00
kaiyi.lk 610ab04ec7 [ISSUE #3949] add test cases 2022-07-13 11:29:37 +08:00
kaiyi.lk bb5e55df16 [ISSUE #3949] add shutdown in ClusterMetadataService 2022-07-13 11:29:36 +08:00
kaiyi.lk 95b8105ffa [ISSUE #3949] support config retryPolicy and consumeMessageOrderly in subscriptionGroupConfig 2022-07-13 11:29:36 +08:00
kaiyi.lk 20e9bdd3e4 [ISSUE #3949] v2 support 2022-07-13 11:29:36 +08:00
zhouxiang 9fe1bbc4df [ISSUE #3949] Fix configuration 2022-07-13 11:29:36 +08:00
zhouxiang 966672ab2d [ISSUE #3949] Add MetadataService 2022-07-13 11:29:35 +08:00
zhouxiang 172d610dc7 [ISSUE #3949] Add enableTopicMessageTypeCheck 2022-07-13 11:29:35 +08:00
kaiyi.lk 7c322c8ab8 [ISSUE #3949] support topic message type 2022-07-13 11:29:35 +08:00
Jixiang.jjx 418ced880e [ISSUE #3949] improve readability. 2022-07-13 11:29:35 +08:00
尘央 fc1b26706a Add ServiceManagerFactory 2022-07-13 11:29:34 +08:00
kaiyi.lk 1451bf5558 [ISSUE #3949] v2 support 2022-07-13 11:29:34 +08:00
尘央 c04c3185e5 Rename ProxyOutResult to ProxyRelayResult 2022-07-13 11:29:34 +08:00
尘央 f91a4c0ee2 Rename ProxyOutService to ProxyRelayService 2022-07-13 11:29:34 +08:00
kaiyi.lk 48a46f0f88 refactor: [ISSUE #3949] v2 support 2022-07-13 11:29:34 +08:00
kaiyi.lk e549a67be3 refactor: [ISSUE #3949] v2 support 2022-07-13 11:29:33 +08:00
zhouxiang d6720b5689 [ISSUE #3949] Interceptor 
* Add GlobalExceptionInterceptor
* Catch AclException in AuthenticationInterceptor
 2022-07-13 11:29:32 +08:00
zhouxiang 7c77f4c324 [ISSUE #3949] AddHeader in AuthenticationInterceptor 2022-07-13 11:29:32 +08:00
zhouxiang 835714666e [ISSUE #3949] Reserve time for longpolling 2022-07-13 11:29:32 +08:00
zhouxiang 56c393f00c [ISSUE #3949] AddHeader in AuthenticationInterceptor 2022-07-13 11:29:32 +08:00
kaiyi.lk 67d749b569 [ISSUE #3949] v2 support 2022-07-13 11:29:29 +08:00
Jixiang.jjx d08dfce4fc [ISSUE #3949] allow to add user-defined gRPC Server interceptors. 2022-07-13 11:29:29 +08:00
Jixiang.jjx 2d594814b8 [ISSUE #3949] allow to config interceptor during building steps. 2022-07-13 11:29:29 +08:00
kaiyi.lk 3ede21afbb [ISSUE #3949] v2 support 2022-07-13 11:29:29 +08:00
zhouxiang 6d57eef4c9 [ISSUE #3949] Add unit test 2022-07-13 11:29:28 +08:00
zhouxiang 78aaf3b19c [ISSUE #3949] Format and clean code 2022-07-13 11:29:28 +08:00
zhouxiang 86284b4e1e [ISSUE #3949] Modify default configuration location 2022-07-13 11:29:28 +08:00
zhouxiang b7fa178d83 [ISSUE #3949] Fix unit test 2022-07-13 11:29:28 +08:00
kaiyi.lk afcade74cf [ISSUE #3949] v2 support 2022-07-13 11:29:27 +08:00
zhouxiang 30aa97317b [ISSUE #3949] Pass checkstyle 2022-07-13 11:29:27 +08:00
kaiyi.lk 0021647704 [ISSUE #3949] v2 support 2022-07-13 11:29:27 +08:00
zhouxiang 9b88806a83 [ISSUE #3949] Remove unused finally 2022-07-13 11:29:27 +08:00
zhouxiang 4cc05ebf11 [ISSUE #3949] Remove v1 package 2022-07-13 11:29:26 +08:00
kaiyi.lk 24742fbba0 [ISSUE #3949] v2 support 2022-07-13 11:29:26 +08:00
kaiyi.lk 8dc4d516d7 [ISSUE #3949] v2 support 2022-07-13 11:29:26 +08:00
kaiyi.lk 9f090e2450 [ISSUE #3949] v2 support 2022-07-13 11:29:26 +08:00
zhouxiang 24467eabc6 [ISSUE #3949] Fetch Endpoints from request 2022-07-13 11:29:25 +08:00
zhouxiang e65ff135b9 [ISSUE #3949] Remove v1 package 2022-07-13 11:29:25 +08:00
zhouxiang f41b7eae6d [ISSUE #3949] Fix ChannelManager 2022-07-13 11:29:24 +08:00
zhouxiang 36347554cf [ISSUE #3949] Remove unused variables 2022-07-13 11:29:24 +08:00
zhouxiang b47944321e [ISSUE #3949] Do refector and Fix unit test 
* Create Channel use Context
* Use LocalReceiveMessageResponseStreamWriter to write ReceiveMessageResponse
* Change polling time to 1 second to reduce test time
 2022-07-13 11:29:23 +08:00
kaiyi.lk f36f3c799d [ISSUE #3949] v2 support 2022-07-13 11:29:23 +08:00
kaiyi.lk de94a70652 [ISSUE #3949] v2 support 2022-07-13 11:29:23 +08:00
Jixiang.jjx b94dcd0a60 [ISSUE #3949] fix to fit checkStyle. 2022-07-13 11:29:23 +08:00
kaiyi.lk fa26627138 [ISSUE #3949] v2 support 2022-07-13 11:29:23 +08:00
zhouxiang 03a10d5608 [ISSUE #3949] Add local/RouteService 2022-07-13 11:29:23 +08:00
kaiyi.lk 1667fb81f4 [ISSUE #3949] v2 support 2022-07-13 11:29:23 +08:00