apache / rocketmq-clients
File Change Frequency

File change frequency (churn) shows the distribution of file updates (days with at least one commit).

Overview
File Change Frequency Overall
  • There are 585 files with 53,407 lines of code.
    • 0 files changed more than 100 times (0 lines of code)
    • 0 files changed 51-100 times (0 lines of code)
    • 7 files changed 21-50 times (3,087 lines of code)
    • 90 files changed 6-20 times (15,061 lines of code)
    • 488 files changed 1-5 times (35,259 lines of code)
0% | 0% | 5% | 28% | 66%
Legend:
101+
51-100
21-50
6-20
1-5

explore: grouped by folders | grouped by update frequency | data
Contributors Count Frequency Overall
  • There are 585 files with 53,407 lines of code.
    • 0 files changed by more than 25 contributors (0 lines of code)
    • 0 files changed by 11-25 contributors (0 lines of code)
    • 9 files changed by 6-10 contributors (2,783 lines of code)
    • 185 files changed by 2-5 contributors (26,540 lines of code)
    • 391 files changed by 1 contributor (24,084 lines of code)
0% | 0% | 5% | 49% | 45%
Legend:
26+
11-25
6-10
2-5
1

explore: grouped by folders | grouped by contributors count | data
File Change Frequency per File Extension
hpp, h, java, cc, cs, cpp, php, ipp, ts, py, go, txt, md, yaml, rs, proto, xml, sh, json, gitignore, csproj, cmake, toml, cjs, mod, rst, bzl, in, clang-format, gitmodules, properties, clang-tidy
File Change Frequency per Extension
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 26% | 31% | 42%
cs0% | 0% | 13% | 30% | 55%
cpp0% | 0% | 0% | 51% | 48%
go0% | 0% | 0% | 30% | 69%
rs0% | 0% | 0% | 39% | 60%
proto0% | 0% | 0% | 10% | 89%
h0% | 0% | 0% | 9% | 90%
bzl0% | 0% | 0% | 100% | 0%
xml0% | 0% | 0% | 42% | 57%
toml0% | 0% | 0% | 100% | 0%
py0% | 0% | 0% | 0% | 100%
ts0% | 0% | 0% | 0% | 100%
php0% | 0% | 0% | 0% | 100%
cmake0% | 0% | 0% | 0% | 100%
File Change Frequency per Logical Decomposition
primary
primary (file change frequency)
The number of recorded file updates
101+
51-100
21-50
6-20
1-5
java0% | 0% | 25% | 31% | 42%
csharp0% | 0% | 13% | 30% | 55%
cpp0% | 0% | 0% | 36% | 63%
golang0% | 0% | 0% | 30% | 69%
rust0% | 0% | 0% | 40% | 59%
python0% | 0% | 0% | 0% | 100%
nodejs0% | 0% | 0% | 0% | 100%
php0% | 0% | 0% | 0% | 100%
Most Frequently Changed Files (Top 50)

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
ClientImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 582 37 2022-06-18 2024-01-10 31 2 yangkun.ayk@gmail.com zhouxzhan@apache.org
Producer.cs
in csharp/rocketmq-client-csharp
 357 27 2022-06-17 2025-01-22 27 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
Client.cs
in csharp/rocketmq-client-csharp
 423 23 2022-06-17 2024-09-19 27 7 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
ProducerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer
 486 23 2022-06-18 2024-12-10 26 5 yangkun.ayk@gmail.com imzs@foxmail.com
PushConsumerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 444 32 2022-06-18 2024-12-27 24 3 yangkun.ayk@gmail.com wuxingcan.wxc@alibaba-inc.com
ProcessQueueImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 560 36 2022-06-18 2024-03-18 24 3 yangkun.ayk@gmail.com szliu0927@gmail.com
ConsumerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 235 9 2022-06-18 2024-01-10 22 5 yangkun.ayk@gmail.com zhouxzhan@apache.org
SimpleConsumerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 241 20 2022-06-18 2024-01-10 19 2 yangkun.ayk@gmail.com zhouxzhan@apache.org
ClientManagerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 411 15 2022-06-18 2024-12-10 19 3 yangkun.ayk@gmail.com imzs@foxmail.com
client.rs
in rust/src
 1155 8 2022-07-29 2024-08-08 19 4 lizhanhui@gmail.com qipingluo@tencent.com
SimpleConsumer.cs
in csharp/rocketmq-client-csharp
 284 20 2022-07-20 2024-09-19 18 5 lizhanhui@gmail.com tsunghanjacktsai@outlook.com
Cargo.toml
in rust
 74 - 2022-07-29 2024-08-08 17 5 lizhanhui@gmail.com qipingluo@tencent.com
client.go
in golang
 614 31 2022-07-14 2024-06-14 17 9 36399867+guyinyou@users.nor... weihubeats@163.com
ClientManager.cs
in csharp/rocketmq-client-csharp
 158 4 2022-06-17 2025-01-22 16 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
MessageView.cs
in csharp/rocketmq-client-csharp
 159 5 2023-02-07 2025-03-25 16 4 yangkun.ayk@gmail.com tsunghanjacktsai@outlook.com
Session.cs
in csharp/rocketmq-client-csharp
 104 4 2022-07-20 2024-08-07 14 4 lizhanhui@gmail.com catcher_hwq@outlook.com
387 20 2022-08-22 2024-05-16 14 7 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
ClientConfig.cs
in csharp/rocketmq-client-csharp
 58 7 2022-06-17 2024-09-19 13 5 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
producer.rs
in rust/src
 171 3 2022-07-29 2024-08-08 13 4 lizhanhui@gmail.com qipingluo@tencent.com
Signature.cs
in csharp/rocketmq-client-csharp
 53 2 2022-06-17 2024-09-19 12 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
session.rs
in rust/src
 112 - 2023-04-04 2024-08-08 12 3 lizhanhui@gmail.com qipingluo@tencent.com
Utilities.cs
in csharp/rocketmq-client-csharp
 130 11 2022-06-17 2025-03-25 12 7 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
RpcClient.cs
in csharp/rocketmq-client-csharp
 155 15 2022-06-17 2025-01-22 12 5 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
IClientManager.cs
in csharp/rocketmq-client-csharp
 35 - 2022-06-17 2025-01-22 11 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
ClientManager.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 61 - 2022-06-18 2024-12-10 11 2 yangkun.ayk@gmail.com imzs@foxmail.com
AsyncSimpleConsumerExample.java
in java/client/src/main/java/org/apache/rocketmq/client/java/example
 78 2 2022-07-28 2023-06-26 11 2 yangkun.ayk@gmail.com yangkun.ayk@alibaba-inc.com
Message.cs
in csharp/rocketmq-client-csharp
 121 11 2022-06-17 2025-01-22 11 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
ClientImpl.h
in cpp/source/rocketmq/include
 130 15 2022-07-14 2025-03-26 11 3 lizhanhui@gmail.com 707364882@qq.com
ClientImpl.cpp
in cpp/source/rocketmq
 501 23 2022-07-14 2025-01-22 11 3 lizhanhui@gmail.com 707364882@qq.com
lib.rs
in rust/src
 36 - 2022-07-29 2024-08-08 10 4 lizhanhui@gmail.com qipingluo@tencent.com
PublishingMessageImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/message
 74 3 2022-06-18 2024-01-10 10 2 yangkun.ayk@gmail.com zhouxzhan@apache.org
SendReceiptImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer
 83 9 2022-06-18 2024-12-10 10 2 yangkun.ayk@gmail.com imzs@foxmail.com
185 - 2023-04-18 2024-08-08 10 2 admin@lv5.moe qipingluo@tencent.com
producer.go
in golang
 396 19 2022-07-04 2024-05-16 10 6 99853473+pherzheyu@users.no... 36399867+guyinyou@users.nor...
ProducerImpl.cpp
in cpp/source/rocketmq
 567 26 2022-07-14 2025-03-26 10 4 lizhanhui@gmail.com 707364882@qq.com
main.go
in golang/example/producer/fifo
 55 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
main.go
in golang/example/producer/async
 55 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
SimpleConsumerExample.java
in java/client/src/main/java/org/apache/rocketmq/client/java/example
 60 2 2022-07-28 2023-06-26 9 2 yangkun.ayk@gmail.com yangkun.ayk@alibaba-inc.com
main.go
in golang/example/producer/transaction
 65 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
Producer.cpp
in cpp/source/rocketmq
 72 8 2022-07-14 2025-03-26 9 3 lizhanhui@gmail.com 707364882@qq.com
MqLogManager.cs
in csharp/rocketmq-client-csharp
 73 5 2022-06-17 2023-10-08 9 5 yangkun.ayk@alibaba-inc.com 772552754@qq.com
PublishingMessage.cs
in csharp/rocketmq-client-csharp
 83 2 2023-02-07 2024-09-19 9 2 yangkun.ayk@gmail.com tsunghanjacktsai@outlook.com
rpc_client.go
in golang
 137 13 2022-07-14 2023-10-16 9 3 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
ClientSessionImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 161 9 2022-07-14 2022-12-07 9 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
RpcClientImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/rpc
 192 17 2022-06-18 2024-12-10 9 2 yangkun.ayk@gmail.com imzs@foxmail.com
265 21 2022-07-14 2024-06-14 9 6 36399867+guyinyou@users.nor... weihubeats@163.com
conf.rs
in rust/src
 306 4 2023-04-04 2024-08-08 9 2 admin@lv5.moe qipingluo@tencent.com
ClientManagerImpl.cpp
in cpp/source/client
 1295 25 2022-07-14 2025-03-26 9 3 lizhanhui@gmail.com 707364882@qq.com
ReceiveMessageResult.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 23 4 2022-06-18 2022-08-08 8 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
logback.xml
in java/client/src/main/resources
 38 - 2022-06-18 2023-02-17 8 2 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
Files With Most Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
client.go
in golang
 614 31 2022-07-14 2024-06-14 17 9 36399867+guyinyou@users.nor... weihubeats@163.com
Client.cs
in csharp/rocketmq-client-csharp
 423 23 2022-06-17 2024-09-19 27 7 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
387 20 2022-08-22 2024-05-16 14 7 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
Utilities.cs
in csharp/rocketmq-client-csharp
 130 11 2022-06-17 2025-03-25 12 7 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
Producer.cs
in csharp/rocketmq-client-csharp
 357 27 2022-06-17 2025-01-22 27 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
ClientManager.cs
in csharp/rocketmq-client-csharp
 158 4 2022-06-17 2025-01-22 16 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
Signature.cs
in csharp/rocketmq-client-csharp
 53 2 2022-06-17 2024-09-19 12 6 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
producer.go
in golang
 396 19 2022-07-04 2024-05-16 10 6 99853473+pherzheyu@users.no... 36399867+guyinyou@users.nor...
265 21 2022-07-14 2024-06-14 9 6 36399867+guyinyou@users.nor... weihubeats@163.com
ProducerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer
 486 23 2022-06-18 2024-12-10 26 5 yangkun.ayk@gmail.com imzs@foxmail.com
ConsumerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 235 9 2022-06-18 2024-01-10 22 5 yangkun.ayk@gmail.com zhouxzhan@apache.org
SimpleConsumer.cs
in csharp/rocketmq-client-csharp
 284 20 2022-07-20 2024-09-19 18 5 lizhanhui@gmail.com tsunghanjacktsai@outlook.com
Cargo.toml
in rust
 74 - 2022-07-29 2024-08-08 17 5 lizhanhui@gmail.com qipingluo@tencent.com
ClientConfig.cs
in csharp/rocketmq-client-csharp
 58 7 2022-06-17 2024-09-19 13 5 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
RpcClient.cs
in csharp/rocketmq-client-csharp
 155 15 2022-06-17 2025-01-22 12 5 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
MqLogManager.cs
in csharp/rocketmq-client-csharp
 73 5 2022-06-17 2023-10-08 9 5 yangkun.ayk@alibaba-inc.com 772552754@qq.com
82 1 2022-07-14 2024-05-16 8 5 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
proto
service.proto
in cpp/proto/apache/rocketmq/v2
 362 - 2022-06-17 2025-01-22 6 5 yangkun.ayk@alibaba-inc.com 707364882@qq.com
client.rs
in rust/src
 1155 8 2022-07-29 2024-08-08 19 4 lizhanhui@gmail.com qipingluo@tencent.com
MessageView.cs
in csharp/rocketmq-client-csharp
 159 5 2023-02-07 2025-03-25 16 4 yangkun.ayk@gmail.com tsunghanjacktsai@outlook.com
Session.cs
in csharp/rocketmq-client-csharp
 104 4 2022-07-20 2024-08-07 14 4 lizhanhui@gmail.com catcher_hwq@outlook.com
producer.rs
in rust/src
 171 3 2022-07-29 2024-08-08 13 4 lizhanhui@gmail.com qipingluo@tencent.com
IClientManager.cs
in csharp/rocketmq-client-csharp
 35 - 2022-06-17 2025-01-22 11 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
Message.cs
in csharp/rocketmq-client-csharp
 121 11 2022-06-17 2025-01-22 11 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
lib.rs
in rust/src
 36 - 2022-07-29 2024-08-08 10 4 lizhanhui@gmail.com qipingluo@tencent.com
ProducerImpl.cpp
in cpp/source/rocketmq
 567 26 2022-07-14 2025-03-26 10 4 lizhanhui@gmail.com 707364882@qq.com
main.go
in golang/example/producer/transaction
 65 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
main.go
in golang/example/producer/async
 55 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
main.go
in golang/example/producer/fifo
 55 1 2022-08-22 2023-05-18 9 4 36399867+guyinyou@users.nor... 770954908@qq.com
utils.go
in golang/pkg/utils
 303 23 2022-08-22 2025-03-19 8 4 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
main.go
in golang/example/consumer/simple_consumer
 64 1 2022-08-22 2023-05-18 8 4 36399867+guyinyou@users.nor... 770954908@qq.com
main.go
in golang/example/producer/delay
 55 1 2022-08-22 2023-05-18 8 4 36399867+guyinyou@users.nor... 770954908@qq.com
main.go
in golang/example/producer/normal
 54 1 2022-08-22 2023-05-18 8 4 36399867+guyinyou@users.nor... 770954908@qq.com
error.rs
in rust/src
 172 3 2022-07-29 2024-08-08 7 4 lizhanhui@gmail.com qipingluo@tencent.com
SendReceipt.cs
in csharp/rocketmq-client-csharp
 42 3 2022-07-20 2025-01-22 7 4 lizhanhui@gmail.com tsunghanjacktsai@outlook.com
conn.go
in golang
 99 4 2022-07-04 2023-04-18 6 4 99853473+pherzheyu@users.no... fuzhi.lfz@alibaba-inc.com
TopicRouteData.cs
in csharp/rocketmq-client-csharp
 76 7 2022-06-17 2024-09-19 6 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
128 14 2022-07-04 2023-03-30 5 4 99853473+pherzheyu@users.no... 69080338+anakin100100@users...
config.go
in golang
 8 - 2022-07-04 2023-03-22 5 4 99853473+pherzheyu@users.no... yangkun.ayk@gmail.com
MetadataConstants.cs
in csharp/rocketmq-client-csharp
 43 1 2022-06-17 2023-03-15 5 4 yangkun.ayk@alibaba-inc.com yangkun.ayk@gmail.com
ClientLoggerInterceptor.cs
in csharp/rocketmq-client-csharp
 83 8 2022-06-17 2023-10-08 5 4 yangkun.ayk@alibaba-inc.com 772552754@qq.com
proto
definition.proto
in cpp/proto/apache/rocketmq/v2
 462 - 2022-06-17 2025-01-22 5 4 yangkun.ayk@alibaba-inc.com 707364882@qq.com
83 9 2022-07-04 2023-04-18 4 4 99853473+pherzheyu@users.no... fuzhi.lfz@alibaba-inc.com
IRpcClient.cs
in csharp/rocketmq-client-csharp
 30 - 2022-06-17 2025-01-22 4 4 yangkun.ayk@alibaba-inc.com tsunghanjacktsai@outlook.com
ProcessQueueImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 560 36 2022-06-18 2024-03-18 24 3 yangkun.ayk@gmail.com szliu0927@gmail.com
PushConsumerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer
 444 32 2022-06-18 2024-12-27 24 3 yangkun.ayk@gmail.com wuxingcan.wxc@alibaba-inc.com
ClientManagerImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 411 15 2022-06-18 2024-12-10 19 3 yangkun.ayk@gmail.com imzs@foxmail.com
session.rs
in rust/src
 112 - 2023-04-04 2024-08-08 12 3 lizhanhui@gmail.com qipingluo@tencent.com
ClientImpl.h
in cpp/source/rocketmq/include
 130 15 2022-07-14 2025-03-26 11 3 lizhanhui@gmail.com 707364882@qq.com
ClientImpl.cpp
in cpp/source/rocketmq
 501 23 2022-07-14 2025-01-22 11 3 lizhanhui@gmail.com 707364882@qq.com
Files With Least Contributors (Top 50)
Based on the number of unique email addresses found in commits.

See data for all files...

File# lines# unitscreatedlast modified# changes
(days)		# contributorsfirst
contributor		latest
contributor
service.pb.go
in golang/protocol/v2
 2424 235 2022-07-14 2022-08-22 2 1 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
apache.rocketmq.v2.rs
in rust/src/pb
 1885 - 2023-04-23 2023-04-23 1 1 admin@lv5.moe admin@lv5.moe
push_consumer.rs
in rust/src
 1857 11 2024-08-08 2024-08-08 1 1 qipingluo@tencent.com qipingluo@tencent.com
service_pb2_grpc.py
in python/rocketmq/grpc_protocol
 462 32 2024-11-08 2024-11-08 1 1 04081337@163.com 04081337@163.com
proto
definition.proto
in python/rocketmq/grpc_protocol/proto
 460 - 2024-11-08 2024-11-08 1 1 04081337@163.com 04081337@163.com
producer.py
in python/rocketmq/v5/producer
 457 35 2024-11-08 2025-03-31 4 1 04081337@163.com 04081337@163.com
client.py
in python/rocketmq/v5/client
 456 44 2024-11-08 2025-03-04 4 1 04081337@163.com 04081337@163.com
proto
definition.proto
in nodejs/proto/apache/rocketmq/v2
 456 - 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
simple_consumer.py
in python/rocketmq/v5/consumer
 382 33 2024-11-08 2025-03-31 5 1 04081337@163.com 04081337@163.com
proto
definition.proto
in php/protocol/apache/rocketmq/v2
 366 - 2022-11-09 2022-11-09 1 1 xiangqiling5204@gmail.com xiangqiling5204@gmail.com
proto
service.proto
in python/rocketmq/grpc_protocol/proto
 346 - 2024-11-08 2024-11-08 1 1 04081337@163.com 04081337@163.com
proto
service.proto
in nodejs/proto/apache/rocketmq/v2
 338 - 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
FindgRPC.cmake
in cpp/cmake
 315 - 2022-07-28 2022-07-28 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
OpenSSLCompatible.h
in cpp/source/client/include
 289 27 2022-07-14 2022-07-14 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
rpc_client.py
in python/rocketmq/v5/client/connection
 259 20 2024-11-08 2025-03-04 3 1 04081337@163.com 04081337@163.com
admin.pb.go
in golang/protocol/v2
 241 21 2022-07-14 2022-08-22 2 1 36399867+guyinyou@users.nor... 36399867+guyinyou@users.nor...
Definition.php
in php/grpc/GPBMetadata/Apache/Rocketmq/V2
 207 1 2022-11-09 2022-11-09 1 1 xiangqiling5204@gmail.com xiangqiling5204@gmail.com
message.py
in python/rocketmq/v5/model
 203 32 2024-11-08 2025-03-31 5 1 04081337@163.com 04081337@163.com
RpcClient.ts
in nodejs/src/client
 200 20 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
rpc_channel.py
in python/rocketmq/v5/client/connection
 196 25 2024-11-08 2025-03-31 4 1 04081337@163.com 04081337@163.com
Service.php
in php/grpc/GPBMetadata/Apache/Rocketmq/V2
 178 1 2022-11-09 2022-11-09 1 1 xiangqiling5204@gmail.com xiangqiling5204@gmail.com
174 - 2022-07-28 2022-07-28 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
MessageMeterInterceptor.java
in java/client/src/main/java/org/apache/rocketmq/client/java/metrics
 170 8 2022-07-13 2022-11-14 5 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
Endpoints.java
in java/client/src/main/java/org/apache/rocketmq/client/java/route
 162 11 2022-06-18 2022-07-12 2 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
ClientSessionImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl
 161 9 2022-07-14 2022-12-07 9 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
SchedulerImpl.cpp
in cpp/source/scheduler
 155 6 2022-07-14 2022-07-21 2 1 lizhanhui@gmail.com lizhanhui@gmail.com
Endpoints.cs
in csharp/rocketmq-client-csharp
 151 7 2023-02-07 2023-03-15 5 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
ClientMeterManager.java
in java/client/src/main/java/org/apache/rocketmq/client/java/metrics
 139 6 2022-08-23 2023-03-29 8 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
ErrorCategory.cpp
in cpp/source/base
 138 1 2022-07-14 2022-07-14 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
RpcClientManager.ts
in nodejs/src/client
 134 17 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
message_id.rs
in rust/src/model
 132 1 2023-04-12 2023-07-11 2 1 admin@lv5.moe admin@lv5.moe
client_metrics.py
in python/rocketmq/v5/client/metrics
 131 8 2024-11-08 2025-02-11 2 1 04081337@163.com 04081337@163.com
GeneralMessageImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/message
 129 15 2022-08-23 2022-11-09 2 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
ReceiveMessageStreamReader.cpp
in cpp/source/client
 128 2 2022-07-14 2022-07-29 3 1 lizhanhui@gmail.com lizhanhui@gmail.com
ConsumeMessageServiceImpl.cpp
in cpp/source/rocketmq
 115 13 2022-07-14 2023-10-08 3 1 lizhanhui@gmail.com lizhanhui@gmail.com
Message.h
in cpp/include/rocketmq
 113 2 2022-07-14 2022-09-27 3 1 lizhanhui@gmail.com lizhanhui@gmail.com
PushSubscriptionSettings.cs
in csharp/rocketmq-client-csharp
 108 5 2024-09-19 2024-09-19 1 1 tsunghanjacktsai@outlook.com tsunghanjacktsai@outlook.com
MixAll.h
in cpp/source/base/include
 106 2 2022-07-14 2022-07-14 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
PublishingLoadBalancer.java
in java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer
 95 7 2022-07-01 2022-11-02 4 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
topic_route.py
in python/rocketmq/v5/model
 95 16 2024-11-08 2025-03-31 3 1 04081337@163.com 04081337@163.com
TelemetrySession.ts
in nodejs/src/client
 91 4 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
ExponentialBackoffRetryPolicy.java
in java/client/src/main/java/org/apache/rocketmq/client/java/retry
 90 11 2022-06-18 2022-08-09 5 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
MessageImpl.java
in java/client/src/main/java/org/apache/rocketmq/client/java/message
 89 8 2022-06-18 2022-11-09 4 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
CredentialsProvider.cpp
in cpp/source/base
 88 3 2022-07-14 2022-07-14 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
AdminServerImpl.cpp
in cpp/source/admin
 86 3 2022-07-14 2022-07-14 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
85 - 2022-07-28 2022-07-28 1 1 lizhanhui@gmail.com lizhanhui@gmail.com
ClientMeter.java
in java/client/src/main/java/org/apache/rocketmq/client/java/metrics
 83 8 2022-07-13 2022-11-14 7 1 yangkun.ayk@gmail.com yangkun.ayk@gmail.com
messaging_result_checker.py
in python/rocketmq/v5/util
 83 1 2024-11-08 2025-02-11 2 1 04081337@163.com 04081337@163.com
Consumer.ts
in nodejs/src/consumer
 83 5 2023-09-17 2023-09-17 1 1 fengmk2@gmail.com fengmk2@gmail.com
client_configuration.py
in python/rocketmq/v5/client
 82 11 2024-11-08 2025-02-11 3 1 04081337@163.com 04081337@163.com
Correlations

File Size vs. Number of Changes: 585 points

python/rocketmq/v5/util/misc.py x: 79 lines of code y: 5 # changes python/setup.py x: 15 lines of code y: 5 # changes python/example/async_producer_example.py x: 33 lines of code y: 4 # changes python/example/async_simple_consumer_example.py x: 42 lines of code y: 4 # changes python/example/delay_producer_example.py x: 26 lines of code y: 1 # changes python/example/normal_producer_example.py x: 26 lines of code y: 3 # changes python/rocketmq/v5/client/balancer/queue_selector.py x: 68 lines of code y: 3 # changes python/rocketmq/v5/client/connection/rpc_channel.py x: 196 lines of code y: 4 # changes python/rocketmq/v5/consumer/simple_consumer.py x: 382 lines of code y: 5 # changes python/rocketmq/v5/model/message.py x: 203 lines of code y: 5 # changes python/rocketmq/v5/model/topic_route.py x: 95 lines of code y: 3 # changes python/rocketmq/v5/producer/producer.py x: 457 lines of code y: 4 # changes cpp/source/base/Message.cpp x: 61 lines of code y: 4 # changes cpp/source/base/Protocol.cpp x: 116 lines of code y: 2 # changes cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp x: 95 lines of code y: 5 # changes cpp/source/rocketmq/ProcessQueueImpl.cpp x: 182 lines of code y: 4 # changes cpp/source/rocketmq/PushConsumerImpl.cpp x: 533 lines of code y: 7 # changes cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h x: 19 lines of code y: 3 # changes cpp/source/rocketmq/include/ProcessQueue.h x: 30 lines of code y: 3 # changes cpp/source/rocketmq/include/ProcessQueueImpl.h x: 65 lines of code y: 5 # changes cpp/source/rocketmq/include/PushConsumerImpl.h x: 128 lines of code y: 6 # changes cpp/include/rocketmq/Configuration.h x: 48 lines of code y: 4 # changes cpp/include/rocketmq/ErrorCode.h x: 61 lines of code y: 3 # changes cpp/include/rocketmq/Producer.h x: 41 lines of code y: 5 # changes cpp/include/rocketmq/RecallReceipt.h x: 8 lines of code y: 1 # changes cpp/include/rocketmq/SendReceipt.h x: 13 lines of code y: 4 # changes cpp/source/base/Configuration.cpp x: 29 lines of code y: 4 # changes cpp/source/base/include/Protocol.h x: 55 lines of code y: 2 # changes cpp/source/client/ClientManagerImpl.cpp x: 1295 lines of code y: 9 # changes cpp/source/client/RpcClientImpl.cpp x: 123 lines of code y: 3 # changes cpp/source/client/Signature.cpp x: 49 lines of code y: 2 # changes cpp/source/client/include/ClientManager.h x: 62 lines of code y: 3 # changes cpp/source/client/include/ClientManagerImpl.h x: 124 lines of code y: 4 # changes cpp/source/client/include/RpcClientImpl.h x: 60 lines of code y: 2 # changes cpp/source/client/include/SendResult.h x: 12 lines of code y: 2 # changes cpp/source/log/LoggerImpl.cpp x: 100 lines of code y: 3 # changes cpp/source/rocketmq/Producer.cpp x: 72 lines of code y: 9 # changes cpp/source/rocketmq/ProducerImpl.cpp x: 567 lines of code y: 10 # changes cpp/source/rocketmq/SendContext.cpp x: 84 lines of code y: 5 # changes cpp/source/rocketmq/SimpleConsumer.cpp x: 101 lines of code y: 6 # changes cpp/source/rocketmq/SimpleConsumerImpl.cpp x: 338 lines of code y: 7 # changes cpp/source/rocketmq/include/ClientImpl.h x: 130 lines of code y: 11 # changes cpp/source/rocketmq/include/ProducerImpl.h x: 94 lines of code y: 7 # changes csharp/rocketmq-client-csharp/MessageView.cs x: 159 lines of code y: 16 # changes csharp/rocketmq-client-csharp/Utilities.cs x: 130 lines of code y: 12 # changes golang/pkg/utils/utils.go x: 303 lines of code y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java x: 241 lines of code y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java x: 285 lines of code y: 6 # changes nodejs/src/client/BaseClient.ts x: 278 lines of code y: 5 # changes golang/message.go x: 300 lines of code y: 7 # changes python/rocketmq/v5/client/connection/rpc_client.py x: 259 lines of code y: 3 # changes python/rocketmq/v5/client/client_configuration.py x: 82 lines of code y: 3 # changes python/rocketmq/v5/client/metrics/client_metrics.py x: 131 lines of code y: 2 # changes python/rocketmq/v5/model/callback_result.py x: 77 lines of code y: 2 # changes python/rocketmq/v5/model/filter_expression.py x: 16 lines of code y: 2 # changes python/rocketmq/v5/model/metrics.py x: 40 lines of code y: 2 # changes python/rocketmq/v5/model/send_receipt.py x: 20 lines of code y: 2 # changes python/rocketmq/v5/util/client_id.py x: 28 lines of code y: 2 # changes python/rocketmq/v5/util/messaging_result_checker.py x: 83 lines of code y: 2 # changes python/rocketmq/v5/util/signature.py x: 44 lines of code y: 3 # changes cpp/proto/apache/rocketmq/v2/definition.proto x: 462 lines of code y: 5 # changes cpp/proto/apache/rocketmq/v2/service.proto x: 362 lines of code y: 6 # changes cpp/source/client/TelemetryBidiReactor.cpp x: 294 lines of code y: 8 # changes cpp/source/rocketmq/ClientImpl.cpp x: 501 lines of code y: 11 # changes csharp/rocketmq-client-csharp/IClientManager.cs x: 35 lines of code y: 11 # changes csharp/rocketmq-client-csharp/ISendReceipt.cs x: 8 lines of code y: 2 # changes csharp/rocketmq-client-csharp/Producer.cs x: 357 lines of code y: 27 # changes csharp/rocketmq-client-csharp/RecallReceipt.cs x: 15 lines of code y: 1 # changes csharp/rocketmq-client-csharp/RpcClient.cs x: 155 lines of code y: 12 # changes csharp/rocketmq-client-csharp/SendReceipt.cs x: 42 lines of code y: 7 # changes csharp/rocketmq-client-csharp/Error/PayloadEmptyException.cs x: 13 lines of code y: 1 # changes csharp/rocketmq-client-csharp/Message.cs x: 121 lines of code y: 11 # changes csharp/rocketmq-client-csharp/StatusChecker.cs x: 88 lines of code y: 7 # changes cpp/source/client/LogInterceptor.cpp x: 70 lines of code y: 2 # changes cpp/source/client/SessionImpl.cpp x: 24 lines of code y: 6 # changes cpp/source/client/include/TopicRouteData.h x: 34 lines of code y: 2 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java x: 444 lines of code y: 24 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/producer/SendReceipt.java x: 6 lines of code y: 3 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManager.java x: 61 lines of code y: 11 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java x: 411 lines of code y: 19 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java x: 486 lines of code y: 26 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/RecallReceiptImpl.java x: 21 lines of code y: 1 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java x: 83 lines of code y: 10 # changes java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClient.java x: 61 lines of code y: 7 # changes java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java x: 192 lines of code y: 9 # changes java/client/src/main/java/org/apache/rocketmq/client/java/exception/StatusChecker.java x: 85 lines of code y: 5 # changes python/rocketmq/grpc_protocol/__init__.py x: 46 lines of code y: 1 # changes python/rocketmq/grpc_protocol/admin_pb2_grpc.py x: 42 lines of code y: 1 # changes python/rocketmq/grpc_protocol/definition_pb2_grpc.py x: 1 lines of code y: 1 # changes python/rocketmq/grpc_protocol/proto/admin.proto x: 37 lines of code y: 1 # changes python/rocketmq/grpc_protocol/proto/definition.proto x: 460 lines of code y: 1 # changes python/rocketmq/grpc_protocol/proto/service.proto x: 346 lines of code y: 1 # changes python/rocketmq/grpc_protocol/service_pb2_grpc.py x: 462 lines of code y: 1 # changes golang/simple_consumer_options.go x: 144 lines of code y: 6 # changes csharp/rocketmq-client-csharp/Client.cs x: 423 lines of code y: 27 # changes csharp/rocketmq-client-csharp/ClientConfig.cs x: 58 lines of code y: 13 # changes csharp/rocketmq-client-csharp/ConsumeService.cs x: 56 lines of code y: 1 # changes csharp/rocketmq-client-csharp/ConsumeTask.cs x: 32 lines of code y: 1 # changes csharp/rocketmq-client-csharp/Consumer.cs x: 107 lines of code y: 8 # changes csharp/rocketmq-client-csharp/CustomizedBackoffRetryPolicy.cs x: 74 lines of code y: 1 # changes csharp/rocketmq-client-csharp/ProcessQueue.cs x: 617 lines of code y: 2 # changes csharp/rocketmq-client-csharp/PublishingMessage.cs x: 83 lines of code y: 9 # changes csharp/rocketmq-client-csharp/PublishingSettings.cs x: 59 lines of code y: 8 # changes csharp/rocketmq-client-csharp/PushConsumer.cs x: 553 lines of code y: 2 # changes csharp/rocketmq-client-csharp/PushSubscriptionSettings.cs x: 108 lines of code y: 1 # changes csharp/rocketmq-client-csharp/Resource.cs x: 65 lines of code y: 7 # changes csharp/rocketmq-client-csharp/Signature.cs x: 53 lines of code y: 12 # changes csharp/rocketmq-client-csharp/SimpleConsumer.cs x: 284 lines of code y: 18 # changes csharp/rocketmq-client-csharp/SimpleSubscriptionSettings.cs x: 77 lines of code y: 4 # changes csharp/rocketmq-client-csharp/TopicRouteData.cs x: 76 lines of code y: 6 # changes csharp/rocketmq-client-csharp/Transaction.cs x: 101 lines of code y: 5 # changes rust/Cargo.toml x: 74 lines of code y: 17 # changes rust/src/client.rs x: 1155 lines of code y: 19 # changes rust/src/conf.rs x: 306 lines of code y: 9 # changes rust/src/error.rs x: 172 lines of code y: 7 # changes rust/src/lib.rs x: 36 lines of code y: 10 # changes rust/src/model/common.rs x: 54 lines of code y: 7 # changes rust/src/producer.rs x: 171 lines of code y: 13 # changes rust/src/push_consumer.rs x: 1857 lines of code y: 1 # changes rust/src/session.rs x: 112 lines of code y: 12 # changes rust/src/simple_consumer.rs x: 185 lines of code y: 10 # changes rust/src/util.rs x: 361 lines of code y: 6 # changes csharp/rocketmq-client-csharp/Session.cs x: 104 lines of code y: 14 # changes cpp/source/client/include/TelemetryBidiReactor.h x: 53 lines of code y: 3 # changes cpp/source/stats/MetricBidiReactor.cpp x: 100 lines of code y: 4 # changes cpp/source/stats/OpencensusExporter.cpp x: 157 lines of code y: 2 # changes cpp/source/stats/include/MetricBidiReactor.h x: 35 lines of code y: 3 # changes cpp/bazel/rocketmq_deps.bzl x: 164 lines of code y: 6 # changes cpp/source/rocketmq/include/SimpleConsumerImpl.h x: 53 lines of code y: 5 # changes golang/client.go x: 614 lines of code y: 17 # changes golang/client_manager.go x: 265 lines of code y: 9 # changes nodejs/src/consumer/SimpleConsumer.ts x: 96 lines of code y: 2 # changes nodejs/src/message/PublishingMessage.ts x: 73 lines of code y: 2 # changes nodejs/src/producer/Producer.ts x: 235 lines of code y: 2 # changes golang/metadata/metadata.go x: 23 lines of code y: 5 # changes golang/producer.go x: 396 lines of code y: 10 # changes golang/publishing_message.go x: 82 lines of code y: 8 # changes golang/simple_consumer.go x: 387 lines of code y: 14 # changes golang/transaction.go x: 89 lines of code y: 4 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java x: 560 lines of code y: 24 # changes java/client/src/main/java/org/apache/rocketmq/client/java/rpc/Signature.java x: 84 lines of code y: 4 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientConfiguration.java x: 36 lines of code y: 7 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java x: 582 lines of code y: 31 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/Settings.java x: 44 lines of code y: 4 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java x: 235 lines of code y: 22 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushSubscriptionSettings.java x: 120 lines of code y: 5 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerImpl.java x: 241 lines of code y: 19 # changes java/client/src/main/java/org/apache/rocketmq/client/java/message/PublishingMessageImpl.java x: 74 lines of code y: 10 # changes java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerDelayMessageExample.java x: 36 lines of code y: 6 # changes java/client/src/main/java/org/apache/rocketmq/client/java/example/ProducerTransactionMessageExample.java x: 43 lines of code y: 6 # changes golang/rpc_client.go x: 137 lines of code y: 9 # changes cpp/source/rocketmq/ConsumeMessageServiceImpl.cpp x: 115 lines of code y: 3 # changes csharp/rocketmq-client-csharp/ClientMeter.cs x: 47 lines of code y: 3 # changes csharp/rocketmq-client-csharp/ClientMeterManager.cs x: 90 lines of code y: 5 # changes php/protocol/apache/rocketmq/v2/service.proto x: 378 lines of code y: 3 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeTask.java x: 49 lines of code y: 6 # changes nodejs/proto/apache/rocketmq/v2/service.proto x: 338 lines of code y: 1 # changes nodejs/src/client/RpcClient.ts x: 200 lines of code y: 1 # changes nodejs/src/client/RpcClientManager.ts x: 134 lines of code y: 1 # changes nodejs/src/client/TelemetrySession.ts x: 91 lines of code y: 1 # changes nodejs/src/consumer/Consumer.ts x: 83 lines of code y: 1 # changes nodejs/src/exception/StatusChecker.ts x: 76 lines of code y: 1 # changes nodejs/src/message/MessageId.ts x: 70 lines of code y: 1 # changes nodejs/src/producer/PublishingLoadBalancer.ts x: 61 lines of code y: 1 # changes nodejs/src/producer/Transaction.ts x: 47 lines of code y: 1 # changes rust/src/model/message_id.rs x: 132 lines of code y: 2 # changes rust/src/model/mod.rs x: 20 lines of code y: 4 # changes java/client/src/main/java/org/apache/rocketmq/client/java/example/AsyncSimpleConsumerExample.java x: 78 lines of code y: 11 # changes java/client/src/main/java/org/apache/rocketmq/client/java/example/SimpleConsumerExample.java x: 60 lines of code y: 9 # changes golang/example/consumer/simple_consumer/main.go x: 64 lines of code y: 8 # changes golang/example/producer/async/main.go x: 55 lines of code y: 9 # changes golang/example/producer/delay/main.go x: 55 lines of code y: 8 # changes golang/example/producer/transaction/main.go x: 65 lines of code y: 9 # changes rust/build.rs x: 68 lines of code y: 5 # changes rust/src/pb/apache.rocketmq.v2.rs x: 1885 lines of code y: 1 # changes cpp/source/base/UtilAll.cpp x: 157 lines of code y: 3 # changes golang/metric.go x: 177 lines of code y: 5 # changes golang/producer_options.go x: 128 lines of code y: 5 # changes java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java x: 139 lines of code y: 8 # changes golang/config.go x: 8 lines of code y: 5 # changes golang/log.go x: 78 lines of code y: 3 # changes csharp/rocketmq-client-csharp/Endpoints.cs x: 151 lines of code y: 5 # changes csharp/rocketmq-client-csharp/MessageIdGenerator.cs x: 63 lines of code y: 4 # changes csharp/rocketmq-client-csharp/MetadataConstants.cs x: 43 lines of code y: 5 # changes csharp/rocketmq-client-csharp/MetricConstant.cs x: 41 lines of code y: 3 # changes csharp/rocketmq-client-csharp/PublishingLoadBalancer.cs x: 73 lines of code y: 5 # changes csharp/rocketmq-client-csharp/SubscriptionLoadBalancer.cs x: 37 lines of code y: 5 # changes csharp/rocketmq-client-csharp/FilterExpression.cs x: 13 lines of code y: 3 # changes csharp/rocketmq-client-csharp/Broker.cs x: 25 lines of code y: 5 # changes csharp/rocketmq-client-csharp/Address.cs x: 56 lines of code y: 4 # changes csharp/rocketmq-client-csharp/AddressScheme.cs x: 26 lines of code y: 4 # changes csharp/rocketmq-client-csharp/Permission.cs x: 71 lines of code y: 4 # changes csharp/rocketmq-client-csharp/AddressListEqualityComparer.cs x: 29 lines of code y: 2 # changes java/client/src/main/resources/logback.xml x: 38 lines of code y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java x: 13 lines of code y: 6 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientSessionImpl.java x: 161 lines of code y: 9 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/FifoConsumeService.java x: 45 lines of code y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/StandardConsumeService.java x: 46 lines of code y: 7 # changes java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeter.java x: 83 lines of code y: 7 # changes java/client/src/main/java/org/apache/rocketmq/client/java/metrics/MessageMeterInterceptor.java x: 170 lines of code y: 5 # changes php/grpc/GPBMetadata/Apache/Rocketmq/V2/Definition.php x: 207 lines of code y: 1 # changes php/grpc/GPBMetadata/Apache/Rocketmq/V2/Service.php x: 178 lines of code y: 1 # changes php/protocol/apache/rocketmq/v2/definition.proto x: 366 lines of code y: 1 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/Message.java x: 15 lines of code y: 3 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/message/MessageView.java x: 18 lines of code y: 4 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/PublishingLoadBalancer.java x: 95 lines of code y: 4 # changes golang/protocol/v2/admin.pb.go x: 241 lines of code y: 2 # changes golang/protocol/v2/definition.pb.go x: 2602 lines of code y: 3 # changes golang/protocol/v2/service.pb.go x: 2424 lines of code y: 2 # changes golang/protocol/v2/service_grpc.pb.go x: 456 lines of code y: 3 # changes cpp/source/base/MixAll.cpp x: 246 lines of code y: 3 # changes java/client/src/main/java/org/apache/rocketmq/client/java/retry/CustomizedBackoffRetryPolicy.java x: 72 lines of code y: 3 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ReceiveMessageResult.java x: 23 lines of code y: 8 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/consumer/SimpleConsumerBuilder.java x: 13 lines of code y: 5 # changes cpp/source/client/ReceiveMessageStreamReader.cpp x: 128 lines of code y: 3 # changes cpp/source/rocketmq/ConsumeTask.cpp x: 174 lines of code y: 3 # changes cpp/cmake/FindgRPC.cmake x: 315 lines of code y: 1 # changes cpp/cmake/OpenCensusHelpers.cmake x: 85 lines of code y: 1 # changes cpp/source/base/UniqueIdGenerator.cpp x: 62 lines of code y: 2 # changes cpp/tools/fix_copyright.py x: 45 lines of code y: 2 # changes java/client-apis/src/main/java/org/apache/rocketmq/client/apis/ClientException.java x: 17 lines of code y: 7 # changes cpp/source/base/ErrorCategory.cpp x: 138 lines of code y: 1 # changes cpp/source/client/include/OpenSSLCompatible.h x: 289 lines of code y: 1 # changes java/client/src/main/java/org/apache/rocketmq/client/java/route/Endpoints.java x: 162 lines of code y: 2 # changes
31.0
# changes
  min: 1.0
  average: 3.39
  25th percentile: 1.0
  median: 2.0
  75th percentile: 4.0
  max: 31.0
0 2602.0
lines of code
min: 1.0 | average: 91.29 | 25th percentile: 14.0 | median: 37.0 | 75th percentile: 77.5 | max: 2602.0

Number of Contributors vs. Number of Changes: 585 points

python/rocketmq/v5/util/misc.py x: 1 # contributors y: 5 # changes python/example/async_producer_example.py x: 1 # contributors y: 4 # changes python/example/delay_producer_example.py x: 1 # contributors y: 1 # changes python/example/normal_producer_example.py x: 1 # contributors y: 3 # changes cpp/source/base/Message.cpp x: 2 # contributors y: 4 # changes cpp/source/base/Protocol.cpp x: 2 # contributors y: 2 # changes cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp x: 2 # contributors y: 5 # changes cpp/source/rocketmq/PushConsumerImpl.cpp x: 2 # contributors y: 7 # changes cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h x: 2 # contributors y: 3 # changes cpp/source/rocketmq/include/PushConsumerImpl.h x: 2 # contributors y: 6 # changes cpp/include/rocketmq/Configuration.h x: 3 # contributors y: 4 # changes cpp/include/rocketmq/ErrorCode.h x: 3 # contributors y: 3 # changes cpp/source/client/ClientManagerImpl.cpp x: 3 # contributors y: 9 # changes cpp/source/rocketmq/ProducerImpl.cpp x: 4 # contributors y: 10 # changes cpp/source/rocketmq/SendContext.cpp x: 3 # contributors y: 5 # changes cpp/source/rocketmq/SimpleConsumer.cpp x: 3 # contributors y: 6 # changes cpp/source/rocketmq/include/ClientImpl.h x: 3 # contributors y: 11 # changes csharp/rocketmq-client-csharp/MessageView.cs x: 4 # contributors y: 16 # changes csharp/rocketmq-client-csharp/Utilities.cs x: 7 # contributors y: 12 # changes golang/pkg/utils/utils.go x: 4 # contributors y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java x: 2 # contributors y: 8 # changes golang/message.go x: 3 # contributors y: 7 # changes python/rocketmq/v5/client/metrics/client_metrics.py x: 1 # contributors y: 2 # changes cpp/proto/apache/rocketmq/v2/definition.proto x: 4 # contributors y: 5 # changes cpp/proto/apache/rocketmq/v2/service.proto x: 5 # contributors y: 6 # changes cpp/source/client/TelemetryBidiReactor.cpp x: 3 # contributors y: 8 # changes csharp/rocketmq-client-csharp/ClientManager.cs x: 6 # contributors y: 16 # changes csharp/rocketmq-client-csharp/IClientManager.cs x: 4 # contributors y: 11 # changes csharp/rocketmq-client-csharp/IRpcClient.cs x: 4 # contributors y: 4 # changes csharp/rocketmq-client-csharp/Producer.cs x: 6 # contributors y: 27 # changes csharp/rocketmq-client-csharp/RpcClient.cs x: 5 # contributors y: 12 # changes csharp/rocketmq-client-csharp/SendReceipt.cs x: 4 # contributors y: 7 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java x: 3 # contributors y: 24 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManager.java x: 2 # contributors y: 11 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java x: 3 # contributors y: 19 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java x: 5 # contributors y: 26 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java x: 2 # contributors y: 10 # changes java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java x: 2 # contributors y: 9 # changes csharp/rocketmq-client-csharp/Client.cs x: 7 # contributors y: 27 # changes csharp/rocketmq-client-csharp/ClientConfig.cs x: 5 # contributors y: 13 # changes csharp/rocketmq-client-csharp/Signature.cs x: 6 # contributors y: 12 # changes csharp/rocketmq-client-csharp/SimpleConsumer.cs x: 5 # contributors y: 18 # changes csharp/rocketmq-client-csharp/TopicRouteData.cs x: 4 # contributors y: 6 # changes rust/Cargo.toml x: 5 # contributors y: 17 # changes rust/src/client.rs x: 4 # contributors y: 19 # changes rust/src/producer.rs x: 4 # contributors y: 13 # changes rust/src/session.rs x: 3 # contributors y: 12 # changes csharp/rocketmq-client-csharp/Session.cs x: 4 # contributors y: 14 # changes golang/client.go x: 9 # contributors y: 17 # changes golang/client_manager.go x: 6 # contributors y: 9 # changes golang/producer.go x: 6 # contributors y: 10 # changes golang/publishing_message.go x: 5 # contributors y: 8 # changes golang/simple_consumer.go x: 7 # contributors y: 14 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java x: 2 # contributors y: 31 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java x: 5 # contributors y: 22 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/SimpleConsumerImpl.java x: 2 # contributors y: 19 # changes csharp/rocketmq-client-csharp/MqLogManager.cs x: 5 # contributors y: 9 # changes golang/example/producer/async/main.go x: 4 # contributors y: 9 # changes java/client/src/main/java/org/apache/rocketmq/client/java/metrics/ClientMeterManager.java x: 1 # contributors y: 8 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/Client.java x: 1 # contributors y: 6 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientSessionImpl.java x: 1 # contributors y: 9 # changes java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumeService.java x: 1 # contributors y: 7 # changes
31.0
# changes
  min: 1.0
  average: 3.39
  25th percentile: 1.0
  median: 2.0
  75th percentile: 4.0
  max: 31.0
0 9.0
# contributors
min: 1.0 | average: 1.61 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 9.0

Number of Contributors vs. File Size: 585 points

python/rocketmq/v5/util/misc.py x: 1 # contributors y: 79 lines of code python/setup.py x: 1 # contributors y: 15 lines of code python/example/async_producer_example.py x: 1 # contributors y: 33 lines of code python/example/async_simple_consumer_example.py x: 1 # contributors y: 42 lines of code python/example/delay_producer_example.py x: 1 # contributors y: 26 lines of code python/rocketmq/v5/client/balancer/queue_selector.py x: 1 # contributors y: 68 lines of code python/rocketmq/v5/client/connection/rpc_channel.py x: 1 # contributors y: 196 lines of code python/rocketmq/v5/consumer/simple_consumer.py x: 1 # contributors y: 382 lines of code python/rocketmq/v5/model/topic_route.py x: 1 # contributors y: 95 lines of code python/rocketmq/v5/producer/producer.py x: 1 # contributors y: 457 lines of code cpp/source/base/Message.cpp x: 2 # contributors y: 61 lines of code cpp/source/base/Protocol.cpp x: 2 # contributors y: 116 lines of code cpp/source/rocketmq/AsyncReceiveMessageCallback.cpp x: 2 # contributors y: 95 lines of code cpp/source/rocketmq/ProcessQueueImpl.cpp x: 2 # contributors y: 182 lines of code cpp/source/rocketmq/PushConsumerImpl.cpp x: 2 # contributors y: 533 lines of code cpp/source/rocketmq/include/AsyncReceiveMessageCallback.h x: 2 # contributors y: 19 lines of code cpp/source/rocketmq/include/ProcessQueue.h x: 2 # contributors y: 30 lines of code cpp/source/rocketmq/include/ProcessQueueImpl.h x: 2 # contributors y: 65 lines of code cpp/source/rocketmq/include/PushConsumerImpl.h x: 2 # contributors y: 128 lines of code cpp/include/rocketmq/Configuration.h x: 3 # contributors y: 48 lines of code cpp/include/rocketmq/ErrorCode.h x: 3 # contributors y: 61 lines of code cpp/include/rocketmq/Producer.h x: 2 # contributors y: 41 lines of code cpp/include/rocketmq/RecallReceipt.h x: 1 # contributors y: 8 lines of code cpp/source/base/Configuration.cpp x: 3 # contributors y: 29 lines of code cpp/source/client/ClientManagerImpl.cpp x: 3 # contributors y: 1295 lines of code cpp/source/client/include/ClientManagerImpl.h x: 3 # contributors y: 124 lines of code cpp/source/rocketmq/Producer.cpp x: 3 # contributors y: 72 lines of code cpp/source/rocketmq/ProducerImpl.cpp x: 4 # contributors y: 567 lines of code cpp/source/rocketmq/PushConsumer.cpp x: 3 # contributors y: 31 lines of code cpp/source/rocketmq/SendContext.cpp x: 3 # contributors y: 84 lines of code cpp/source/rocketmq/SimpleConsumer.cpp x: 3 # contributors y: 101 lines of code cpp/source/rocketmq/SimpleConsumerImpl.cpp x: 2 # contributors y: 338 lines of code csharp/rocketmq-client-csharp/MessageView.cs x: 4 # contributors y: 159 lines of code csharp/rocketmq-client-csharp/Utilities.cs x: 7 # contributors y: 130 lines of code golang/pkg/utils/utils.go x: 4 # contributors y: 303 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/message/MessageViewImpl.java x: 2 # contributors y: 241 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/misc/Utilities.java x: 2 # contributors y: 285 lines of code nodejs/src/client/BaseClient.ts x: 3 # contributors y: 278 lines of code golang/message.go x: 3 # contributors y: 300 lines of code python/rocketmq/v5/client/connection/rpc_client.py x: 1 # contributors y: 259 lines of code python/rocketmq/v5/client/client_configuration.py x: 1 # contributors y: 82 lines of code python/rocketmq/v5/client/metrics/client_metrics.py x: 1 # contributors y: 131 lines of code python/rocketmq/v5/util/message_id_codec.py x: 1 # contributors y: 60 lines of code cpp/proto/apache/rocketmq/v2/definition.proto x: 4 # contributors y: 462 lines of code cpp/proto/apache/rocketmq/v2/service.proto x: 5 # contributors y: 362 lines of code cpp/source/client/TelemetryBidiReactor.cpp x: 3 # contributors y: 294 lines of code cpp/source/rocketmq/ClientImpl.cpp x: 3 # contributors y: 501 lines of code csharp/rocketmq-client-csharp/ClientManager.cs x: 6 # contributors y: 158 lines of code csharp/rocketmq-client-csharp/IClientManager.cs x: 4 # contributors y: 35 lines of code csharp/rocketmq-client-csharp/IRpcClient.cs x: 4 # contributors y: 30 lines of code csharp/rocketmq-client-csharp/ISendReceipt.cs x: 2 # contributors y: 8 lines of code csharp/rocketmq-client-csharp/Producer.cs x: 6 # contributors y: 357 lines of code csharp/rocketmq-client-csharp/RpcClient.cs x: 5 # contributors y: 155 lines of code csharp/rocketmq-client-csharp/SendReceipt.cs x: 4 # contributors y: 42 lines of code csharp/rocketmq-client-csharp/Message.cs x: 4 # contributors y: 121 lines of code cpp/source/client/include/TopicRouteData.h x: 2 # contributors y: 34 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/PushConsumerImpl.java x: 3 # contributors y: 444 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientManagerImpl.java x: 3 # contributors y: 411 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/ProducerImpl.java x: 5 # contributors y: 486 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/producer/SendReceiptImpl.java x: 2 # contributors y: 83 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/rpc/RpcClientImpl.java x: 2 # contributors y: 192 lines of code python/rocketmq/grpc_protocol/proto/service.proto x: 1 # contributors y: 346 lines of code python/rocketmq/grpc_protocol/service_pb2_grpc.py x: 1 # contributors y: 462 lines of code golang/simple_consumer_options.go x: 3 # contributors y: 144 lines of code csharp/rocketmq-client-csharp/Client.cs x: 7 # contributors y: 423 lines of code csharp/rocketmq-client-csharp/ClientConfig.cs x: 5 # contributors y: 58 lines of code csharp/rocketmq-client-csharp/Consumer.cs x: 2 # contributors y: 107 lines of code csharp/rocketmq-client-csharp/ExponentialBackoffRetryPolicy.cs x: 2 # contributors y: 79 lines of code csharp/rocketmq-client-csharp/ProcessQueue.cs x: 2 # contributors y: 617 lines of code csharp/rocketmq-client-csharp/PushConsumer.cs x: 2 # contributors y: 553 lines of code csharp/rocketmq-client-csharp/PushSubscriptionSettings.cs x: 1 # contributors y: 108 lines of code csharp/rocketmq-client-csharp/Signature.cs x: 6 # contributors y: 53 lines of code csharp/rocketmq-client-csharp/SimpleConsumer.cs x: 5 # contributors y: 284 lines of code csharp/rocketmq-client-csharp/TopicRouteData.cs x: 4 # contributors y: 76 lines of code rust/Cargo.toml x: 5 # contributors y: 74 lines of code rust/src/client.rs x: 4 # contributors y: 1155 lines of code rust/src/conf.rs x: 2 # contributors y: 306 lines of code rust/src/error.rs x: 4 # contributors y: 172 lines of code rust/src/push_consumer.rs x: 1 # contributors y: 1857 lines of code rust/src/session.rs x: 3 # contributors y: 112 lines of code rust/src/util.rs x: 3 # contributors y: 361 lines of code csharp/rocketmq-client-csharp/Session.cs x: 4 # contributors y: 104 lines of code cpp/source/stats/OpencensusExporter.cpp x: 2 # contributors y: 157 lines of code cpp/bazel/rocketmq_deps.bzl x: 2 # contributors y: 164 lines of code golang/client.go x: 9 # contributors y: 614 lines of code golang/client_manager.go x: 6 # contributors y: 265 lines of code nodejs/src/producer/Producer.ts x: 2 # contributors y: 235 lines of code golang/producer.go x: 6 # contributors y: 396 lines of code golang/publishing_message.go x: 5 # contributors y: 82 lines of code golang/simple_consumer.go x: 7 # contributors y: 387 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ProcessQueueImpl.java x: 3 # contributors y: 560 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientImpl.java x: 2 # contributors y: 582 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/consumer/ConsumerImpl.java x: 5 # contributors y: 235 lines of code golang/rpc_client.go x: 3 # contributors y: 137 lines of code cpp/source/rocketmq/ConsumeMessageServiceImpl.cpp x: 1 # contributors y: 115 lines of code csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs x: 4 # contributors y: 83 lines of code php/protocol/apache/rocketmq/v2/service.proto x: 3 # contributors y: 378 lines of code nodejs/proto/apache/rocketmq/v2/service.proto x: 1 # contributors y: 338 lines of code nodejs/src/client/RpcClientManager.ts x: 1 # contributors y: 134 lines of code golang/example/consumer/simple_consumer/main.go x: 4 # contributors y: 64 lines of code golang/example/producer/async/main.go x: 4 # contributors y: 55 lines of code rust/src/pb/apache.rocketmq.v2.rs x: 1 # contributors y: 1885 lines of code golang/conn.go x: 4 # contributors y: 99 lines of code golang/metric.go x: 3 # contributors y: 177 lines of code golang/producer_options.go x: 4 # contributors y: 128 lines of code golang/config.go x: 4 # contributors y: 8 lines of code golang/consumer.go x: 3 # contributors y: 9 lines of code csharp/rocketmq-client-csharp/Endpoints.cs x: 1 # contributors y: 151 lines of code csharp/rocketmq-client-csharp/MessageIdGenerator.cs x: 3 # contributors y: 63 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/impl/ClientSessionImpl.java x: 1 # contributors y: 161 lines of code java/client/src/main/java/org/apache/rocketmq/client/java/metrics/MessageMeterInterceptor.java x: 1 # contributors y: 170 lines of code php/grpc/GPBMetadata/Apache/Rocketmq/V2/Definition.php x: 1 # contributors y: 207 lines of code php/grpc/GPBMetadata/Apache/Rocketmq/V2/Service.php x: 1 # contributors y: 178 lines of code php/protocol/apache/rocketmq/v2/definition.proto x: 1 # contributors y: 366 lines of code golang/protocol/v2/admin.pb.go x: 1 # contributors y: 241 lines of code golang/protocol/v2/definition.pb.go x: 2 # contributors y: 2602 lines of code golang/protocol/v2/service.pb.go x: 1 # contributors y: 2424 lines of code golang/protocol/v2/service_grpc.pb.go x: 2 # contributors y: 456 lines of code cpp/source/base/MixAll.cpp x: 2 # contributors y: 246 lines of code cpp/cmake/FindgRPC.cmake x: 1 # contributors y: 315 lines of code cpp/source/client/include/OpenSSLCompatible.h x: 1 # contributors y: 289 lines of code
2602.0
lines of code
  min: 1.0
  average: 91.29
  25th percentile: 14.0
  median: 37.0
  75th percentile: 77.5
  max: 2602.0
0 9.0
# contributors
min: 1.0 | average: 1.61 | 25th percentile: 1.0 | median: 1.0 | 75th percentile: 2.0 | max: 9.0