File tree
2,090 files changed
+193651
-24253
lines changed- .github
- ISSUE_TEMPLATE
- workflows
- acl
- src
- main/java/org/apache/rocketmq/acl
- common
- plain
- test
- java/org/apache/rocketmq/acl
- common
- plain
- resources
- access_acl_conf/acl
- both_acl_file_folder_conf/conf
- acl
- conf
- acl
- empty_acl_folder_conf/conf
- only_acl_folder_conf/conf/acl
- update_global_white_addr/conf
- acl
- bazel
- broker
- src
- main
- java/org/apache/rocketmq/broker
- client
- net
- rebalance
- coldctr
- controller
- dledger
- failover
- filter
- filtersrv
- latency
- loadbalance
- longpolling
- metrics
- mqtrace
- offset
- out
- pagecache
- plugin
- processor
- schedule
- slave
- subscription
- topic
- transaction
- jdbc
- queue
- util
- resources
- META-INF/service
- test
- java/org/apache/rocketmq/broker
- client
- controller
- failover
- filter
- latency
- longpolling
- metrics
- offset
- pagecache
- processor
- schedule
- subscription
- topic
- transaction/queue
- util
- resources
- client
- src
- main
- java/org/apache/rocketmq/client
- common
- consumer
- rebalance
- store
- exception
- hook
- impl
- admin
- consumer
- factory
- mqclient
- producer
- latency
- log
- producer
- rpchook
- stat
- trace
- hook
- resources
- test
- java/org/apache/rocketmq/client
- common
- consumer
- rebalance
- store
- impl
- consumer
- factory
- latency
- producer
- selector
- rpchook
- trace
- resources
- org/powermock/extensions
- common
- src
- main
- java/org/apache/rocketmq/common
- attribute
- coldctr
- compression
- config
- consistenthash
- constant
- consumer
- fastjson
- filter/impl
- future
- help
- logging
- message
- metrics
- namesrv
- protocol
- header
- route
- queue
- state
- statistics
- stats
- sysflag
- thread
- topic
- utils
- resources/META-INF/services
- test
- java/org/apache/rocketmq/common
- attribute
- compression
- message
- protocol/topic
- stats
- sysflag
- topic
- utils
- resources
- container
- src
- main/java/org/apache/rocketmq/container
- logback
- test
- java/org/apache/rocketmq/container
- resources
- controller
- src
- main
- java/org/apache/rocketmq/controller
- elect
- impl
- helper
- impl
- closure
- event
- heartbeat
- manager
- task
- metrics
- processor
- resources
- test
- java/org/apache/rocketmq/controller
- impl
- manager
- resources
- dev
- distribution
- benchmark
- bin
- controller
- conf
- container/2container-2m-2s
- controller
- cluster-3n-independent
- cluster-3n-namesrv-plugin
- quick-start
- docs
- cn
- acl
- client/java
- controller
- dledger
- image
- controller
- persistent_unique_broker_id
- quick-start
- msg_trace
- proxy
- statictopic
- en
- acl
- client/java
- controller
- dledger
- image/controller
- persistent_unique_broker_id
- quick-start
- images
- msg_trace
- proxy
- example
- src/main/java/org/apache/rocketmq/example
- batch
- benchmark
- timer
- broadcast
- filter
- namespace
- openmessaging
- operation
- ordermessage
- quickstart
- rpc
- schedule
- simple
- tracemessage
- transaction
- filter
- src
- main/java/org/apache/rocketmq/filter
- expression
- parser
- util
- test
- java/org/apache/rocketmq/filter
- resources
- logging/src
- main/java/org/apache/rocketmq/logging
- inner
- test
- java/org/apache/rocketmq/logging
- inner
- resources
- namesrv
- src
- main
- java/org/apache/rocketmq/namesrv
- kvconfig
- processor
- route
- routeinfo
- resources
- test
- java/org/apache/rocketmq/namesrv
- processor
- routeinfo
- resources
- openmessaging
- src
- main/java/io/openmessaging/rocketmq
- consumer
- producer
- promise
- utils
- test/resources
- proxy
- src
- main
- java/org/apache/rocketmq/proxy
- common
- channel
- utils
- config
- grpc
- constant
- interceptor
- v2
- channel
- client
- common
- consumer
- producer
- route
- transaction
- metrics
- processor
- channel
- validator
- remoting
- activity
- channel
- common
- pipeline
- protocol
- http2proxy
- remoting
- service
- admin
- channel
- client
- message
- metadata
- receipt
- relay
- route
- sysmessage
- transaction
- resources
- test
- java/org/apache/rocketmq/proxy
- common
- utils
- config
- grpc
- v2
- channel
- client
- common
- consumer
- producer
- route
- transaction
- processor
- channel
- remoting
- activity
- channel
- protocol/http2proxy
- service
- admin
- message
- metadata
- mqclient
- receipt
- relay
- route
- sysmessage
- transaction
- resources
- mockito-extensions
- rmq-proxy-home/conf
- remoting
- src
- main/java/org/apache/rocketmq/remoting
- common
- metrics
- netty
- protocol
- admin
- body
- filter
- header
- controller
- admin
- register
- namesrv
- heartbeat
- namesrv
- route
- statictopic
- subscription
- topic
- proxy
- rpc
- rpchook
- test
- java/org/apache/rocketmq/remoting
- netty
- protocol
- admin
- body
- filter
- header
- heartbeat
- route
- statictopic
- subscription
- topic
- rpc
- resources
- srvutil
- src
- main/java/org/apache/rocketmq/srvutil
- test
- java/org/apache/rocketmq/srvutil
- resources
- store
- src
- main/java/org/apache/rocketmq/store
- config
- dledger
- ha
- autoswitch
- io
- hook
- index
- kv
- logfile
- metrics
- plugin
- pop
- queue
- rocksdb
- stats
- timer
- util
- test
- java/org/apache/rocketmq/store
- dledger
- ha
- autoswitch
- index
- kv
- logfile
- pop
- queue
- stats
- timer
- resources
- style
- test
- src
- main/java/org/apache/rocketmq/test
- client
- mq
- rmq
- clientinterface
- factory
- listener
- rmq
- concurrent
- order
- lmq/benchmark
- schema
- util
- test
- java/org/apache/rocketmq/test
- autoswitchrole
- base
- client
- consumer
- balance
- broadcast
- normal
- order
- tag
- cluster
- filter
- pop
- tag
- topic
- producer
- async
- batch
- exception
- msg
- producer
- oneway
- order
- querymsg
- transaction
- container
- delay
- dledger
- grpc/v2
- lmq
- offset
- retry
- route
- schema
- smoke
- statictopic
- tls
- resources
- rmq-proxy-home/conf
- schema
- api
- protocol
- tieredstore
- src
- main/java/org/apache/rocketmq/tieredstore
- common
- exception
- file
- index
- metadata
- metrics
- provider
- posix
- stream
- util
- test
- java/org/apache/rocketmq/tieredstore
- common
- file
- index
- metadata
- metrics
- provider
- memory
- posix
- util
- resources
- tools
- src
- main
- java/org/apache/rocketmq/tools
- admin
- api
- common
- command
- acl
- broker
- cluster
- connection
- consumer
- container
- controller
- export
- ha
- message
- metadata
- namesrv
- offset
- producer
- queue
- stats
- topic
- monitor
- resources
- test
- java/org/apache/rocketmq/tools
- admin
- command
- acl
- broker
- connection
- consumer
- message
- metadata
- namesrv
- offset
- producer
- server
- topic
- monitor
- resources
Some content is hidden
Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.
2,090 files changed
+193651
-24253
lines changed+53
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + |
+69
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + | |
| 76 | + | |
| 77 | + | |
| 78 | + | |
| 79 | + | |
| 80 | + | |
| 81 | + | |
| 82 | + | |
| 83 | + | |
| 84 | + | |
| 85 | + | |
| 86 | + | |
| 87 | + | |
| 88 | + | |
| 89 | + | |
| 90 | + | |
| 91 | + | |
| 92 | + | |
| 93 | + | |
| 94 | + | |
| 95 | + | |
| 96 | + | |
| 97 | + | |
| 98 | + | |
| 99 | + | |
| 100 | + | |
| 101 | + | |
| 102 | + | |
| 103 | + | |
| 104 | + | |
| 105 | + | |
| 106 | + | |
| 107 | + | |
| 108 | + | |
| 109 | + | |
| 110 | + | |
| 111 | + | |
| 112 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + |
Original file line number | Diff line number | Diff line change | |
---|---|---|---|
| |||
| 1 | + | |
| 2 | + | |
| 3 | + | |
| 4 | + | |
| 5 | + | |
| 6 | + | |
| 7 | + | |
| 8 | + | |
| 9 | + | |
| 10 | + | |
| 11 | + | |
| 12 | + | |
| 13 | + | |
| 14 | + | |
| 15 | + | |
| 16 | + | |
| 17 | + | |
| 18 | + | |
| 19 | + | |
| 20 | + | |
| 21 | + | |
| 22 | + | |
| 23 | + | |
| 24 | + | |
| 25 | + | |
| 26 | + | |
| 27 | + | |
| 28 | + | |
| 29 | + | |
| 30 | + | |
| 31 | + | |
| 32 | + | |
| 33 | + | |
| 34 | + | |
| 35 | + | |
| 36 | + | |
| 37 | + | |
| 38 | + | |
| 39 | + | |
| 40 | + | |
| 41 | + | |
| 42 | + | |
| 43 | + | |
| 44 | + | |
| 45 | + | |
| 46 | + | |
| 47 | + | |
| 48 | + | |
| 49 | + | |
| 50 | + | |
| 51 | + | |
| 52 | + | |
| 53 | + | |
| 54 | + | |
| 55 | + | |
| 56 | + | |
| 57 | + | |
| 58 | + | |
| 59 | + | |
| 60 | + | |
| 61 | + | |
| 62 | + | |
| 63 | + | |
| 64 | + | |
| 65 | + | |
| 66 | + | |
| 67 | + | |
| 68 | + | |
| 69 | + | |
| 70 | + | |
| 71 | + | |
| 72 | + | |
| 73 | + | |
| 74 | + | |
| 75 | + |
0 commit comments