rocketmq-rust-all-0.4.0

🔊Announcement: RocketMQ Rust 🔖v0.4.0 has been released

New Feature and improve performance

• ✨Fix some bugs
• 🌐 Add rocketmq-rust doc web site
• 🚀 Add new crates: rocketmq-tui and rocketmq-tools
• 🚀 Add some new features

What's Changed

• [ISSUE #1210]✨Update the version to 0.4.0 for development by @mxsm in #1211
• [ISSUE #1212]🐛Fix TopicConfigSerializeWrapper unit test error by @mxsm in #1213
• [ISSUE #1214]🔥Optimize Send message put PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX Property by @mxsm in #1215
• [ISSUE #1216]✅Optimize TransactionalMessageUtil some method⚡️ by @mxsm in #1217
• [ISSUE #1136]🚀Support broker receive transaction message-3 by @mxsm in #1218
• [ISSUE #1219]📝Update README.md by @mxsm in #1220
• [ISSUE #1221]Optimize MappedFile method by @mxsm in #1222
• [ISSUE #1223]Change the return type of the get_transaction_id method in MessageTrait to &CheetahString by @mxsm in #1224
• Bump serde_json from 1.0.132 to 1.0.133 by @dependabot in #1227
• Bump mockall from 0.13.0 to 0.13.1 by @dependabot in #1226
• [ISSUE #1228]🚀Implement Java MessageDecoder class encodeUniquely and encode method by @mxsm in #1229
• [ISSUE #1230]🚀Support broker receive transaction message-4 by @mxsm in #1231
• [ISSUE #1232]Optimize DefaultRequestProcessor code by @mxsm in #1233
• Bump codecov/codecov-action from 5.0.2 to 5.0.3 by @dependabot in #1235
• [ISSUE #1236]Add #[inline] for DefaultRemotingRequestProcessor#process_request by @mxsm in #1237
• [ISSUE #1234]🐛NameServer Cannot drop a runtime in a context where blocking is not allowed by @mxsm in #1238
• [ISSUE #1239]🔥Optimize KVConfigManager code⚡️ by @mxsm in #1240
• [ISSUE #1241]🔨Add Associate Milestone Github Action by @mxsm in #1242
• [ISSUE #1243]🔨Add Associate Milestone Github Action for PR by @mxsm in #1244
• [ISSUE #1245]🔨Update Associate Milestone Github Action CI by @mxsm in #1246
• [ISSUE #1247]🔨Add Sync Issue Labels to PR Github action CI by @mxsm in #1248
• [ISSUE #1249]🍻Optimize RouteInfoManager logic by @mxsm in #1250
• Bump codecov/codecov-action from 5.0.3 to 5.0.6 by @dependabot in #1252
• Bump actions/checkout from 3 to 4 by @dependabot in #1251
• [ISSUE #1254]🚀RocketMQRuntime add schedule_at_fixed_rate_mut method by @mxsm in #1255
• [ISSUE #1256]🔨Update Associate Milestone Github actions CI by @mxsm in #1257
• [ISSUE #1253]⚡️Optimize RouteInfoManager in NameServerBootstrap, remove RouteInfoManager parking_lot::RwLock by @mxsm in #1259
• [ISSUE #1258]🚀Implement RegisterBrokerBody compress encode and decode by @mxsm in #1260
• [ISSUE #1261]⚡️TopicFilterType implement Display by @mxsm in #1262
• [ISSUE #1263]🔨Optimize TopicConfig encode📝 by @mxsm in #1264
• [ISSUE #1265]🐛Fix RegisterBrokerBody decode error by @mxsm in #1266
• [ISSUE #1267]⚡️Optimize Name server DefaultRequestProcessor#query_broker_topic_config by @mxsm in #1268
• Bump tabled from 0.16.0 to 0.17.0 by @dependabot in #1273
• Bump syn from 2.0.87 to 2.0.89 by @dependabot in #1271
• Bump codecov/codecov-action from 5.0.6 to 5.0.7 by @dependabot in #1270
• [ISSUE #1269]⚡️Optimize name server DefaultRequestProcessor#process_register_broker by @mxsm in #1274
• [ISSUE #1275]⚡️Optimize name server DefaultRequestProcessor#get_broker_member_group by @mxsm in #1276
• [ISSUE #1277]⚡️Optimize name server DefaultRequestProcessor#wipe_write_perm_of_broker_by_lock by @mxsm in #1278
• [ISSUE #1279]⚡️Optimize name server DefaultRequestProcessor#get_all_topic_list_from_nameserver by @mxsm in #1280
• [ISSUE #1281]⚡️Optimize name server DefaultRequestProcessor#delete_topic_in_name_srv by @mxsm in #1282
• [ISSUE #1283]⚡️Optimize name server DefaultRequestProcessor by @mxsm in #1284
• [ISSUE #1285]⚡️Optimize name server ClientRequestProcessor#get_route_info_by_topic by @mxsm in #1286
• [ISSUE #1288]⚡️Add doc for MessageSysFlag and optimize code by @mxsm in #1289
• [ISSUE #1303]🚀Add QueryAssignmentRequestBody and QueryAssignmentResponseBody by @mxsm in #1304
• [ISSUE #1305]🚀Add SetMessageRequestModeRequestBody by @mxsm in #1306
• [ISSUE ##1307]🚀Implement MessageRequestModeManager by @mxsm in #1308
• [ISSUE #1310]⚡️Refactor AllocateMessageQueueStrategy by @mxsm in #1311
• [ISSUE #1293]🔥Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueAveragelyByCircle🚀 by @mxsm in #1312
• [ISSUE #1313]🔨Update Github Actions CI by @rocketmq-rust-robot in #1314
• Bump cheetah-string from 0.1.5 to 0.1.6 by @dependabot in #1317
• [ISSUE #90]Support update namesrv config by @PanGan21 in #1316
• [ISSUE #1319]🔨Update Github Actions CI by @mxsm in #1320
• Revert "[ISSUE #1319]🔨Update Github Actions CI" by @mxsm in #1325
• Revert "[ISSUE #1313]🔨Update Github Actions CI" by @mxsm in #1326
• [ISSUE #1323]🔨Update Github Actions CI by @rust-learn-now in #1327
• [ISSUE #1321]🧪Add unit test for OperationResult by @shadowsoy in #1322
• [ISSUE #1328]🧪Add test for ConsumerData by @mxsm in #1329
• [ISSUE #1332]🔨Update Github Actions CI by @mxsm in #1333
• [ISSUE #1336]🔨Update Github Actions CI by @mxsm in #1337
• [ISSUE #1330]🧪Add unit test for MessageModel by @rust-learn-now in #1335
• [ISSUE #1340]🔨Update Github Actions CI by @rust-learn-now in #1341
• [ISSUE #1338]🧪Add Unit test for ProducerData by @what-design in #1339
• 🔨Update Github Actions CI by @rust-learn-now in #1344
• [ISSUE #1345]🔨Update Github Actions CI by @mxsm in #1346
• [ISSUE #1342]🧪Add Unit test for BrokerMemberGroup by @ButterflyEffect1991 in #1343
• [ISSUE #1349]🔨Update Github Actions CI by @ButterflyEffect1991 in #1350
• [ISSUE #1352]🔨Update Github Actions CI by @rust-learn-now in #1353
• [ISSUE #1347]🧪Add unit test for route_data_view by @ButterflyEffect1991 in #1348
• [ISSUE #1354]🔨Update Github Actions CI by @rust-learn-now in #1355
• [ISSUE #1356]🧪Add unit test for CreateTopicRequestHeader by @Fly-cmd-ops in #1357
• [ISSUE #1358]🔨Update Github Actions CI by @mxsm in #1359
• [ISSUE #1360]🧪Add unit test for DeleteTopicRequestHeader by @Fly-cmd-ops in #1361
• [ISSUE #1362]🎨Refactor QueryAssignmentProcessor by @mxsm in #1363
• [ISSUE #1364]🍻Broker Supports request code SetMessageRequestMode (401) by @mxsm in #1365
• [ISSUE #1368]📝Update README.md by @mxsm in #1369
• [ISSUE #1370]🚀Add PlainAccessConfig by @mxsm in #1371
• [ISSUE #1372]🚀Add ClusterAclVersionInfo by @mxsm in #1373
• [ISSUE #1374]🚀Add CheckRocksdbCqWriteProgressResponseBody and ProducerConnection by @mxsm in #1375
• [ISSUE #1387]🚀Add rocketmq-tools crate🔥 by @mxsm in #1388
• [ISSUE #1389]🔨Update package and publish script🔊 by @mxsm in #1390
• [ISSUE #1391]🚀Add AdminToolResult🔊 by @mxsm in #1392
• [ISSUE #1386]🚀Add MQAdminExt for rocketmq-tools crate by @mxsm in #1393
• [ISSUE #1367]🚀Client Supports request code SetMessageRequestMode (401) by @mxsm in #1395
• Bump sysinfo from 0.32.0 to 0.32.1 by @dependabot in #1394
• [ISSUE #1396]🔥Remove unused crate in rocketmq-store by @mxsm in #1397
• [ISSUE #1398]🔥Implement the TopicRouteInfoManager function🚀 by @mxsm in #1399
• [ISSUE #1400]⚡️Add #[inline] for WeakArcMut and ArcMut by @mxsm in #1401
• [ISSUE #1301]🔥Rocketmq-rust broker supports request code QUERY_ASSIGNMENT(400)🚀 by @mxsm in #1402
• [ISSUE #1403]🚀Remove unused crate in rocketmq-client-rust🔊 by @mxsm in #1404
• [ISSUE #1405]🚀Remove unused crate in rocketmq-common🔊 by @mxsm in #1406
• [ISSUE #1407]🔥Remove unused crate in rocketmq-broker🚨 by @mxsm in #1408
• [ISSUE #1409]🔥Remove unused crate in rocketmq-namesrv🚨 by @mxsm in #1410
• Bump bytes from 1.8.0 to 1.9.0 by @dependabot in #1413
• [ISSUE #1411]🔥BrokerRequestProcessor add QueryAssignmentProcessor logic handle🚨 by @mxsm in #1412
• [ISSUE #1385]🚀Add UserInfo and AclInfo by @mxsm in #1414
• [ISSUE #1302]🔥Rocketmq-rust client supports request code QUERY_ASSIGNMENT(400) by @mxsm in #1415
• [ISSUE #1417]🔥BrokerData and QueueData add Default implement by @mxsm in #1418
• [ISSUE #1416]🐛Fix TopicRouteData Serialize and Deserialize field name error by @mxsm in #1419
• [ISSUE #1420]🚀Add TraceConstants by @mxsm in #1421
• [ISSUE #1423]🚀Add TraceBean by @mxsm in #1424
• [ISSUE #1425]🚀Add TraceType struct by @mxsm in #1427
• [ISSUE #1426]🚀Add TraceContext struct by @mxsm in #1428
• [ISSUE #1430] Add TopicMessageQueueChangeListener trait for client by @mxsm in #1431
• [ISSUE #1429]🔥Add LitePullConsumer trait for client🚧 by @mxsm in #1432
• [ISSUE #1433]🐛Fix LitePullConsumerLocal trait_variant::make error by @mxsm in #1434
• [ISSUE #1435]🔥Update rocketmq-cli Cargo.toml🚨 by @mxsm in #1436
• [ISSUE #1437]🔥Remove unused crate from rocketmq-remoting🚨 by @mxsm in #1440
• [ISSUE #1438]🔥Remove unused crate from rocketmq-runtime🚨 by @mxsm in #1441
• [ISSUE #1439]🔥Remove unused crate from rocketmq-filter🚨 by @mxsm in #1442
• [ISSUE #1443]🔨Add Template for code refactor by @mxsm in #1444
• [ISSUE #1445]🔨Update refactor.yml by @mxsm in #1446
• 🔨Update refactor.yml by @SpaceXCN in #1447
• [ISSUE #1449]🔨Update refactor.yml by @mxsm in #1448
• [ISSUE #1450]🔨Update refactor.yml by @SpaceXCN in #1451
• Bump tracing-subscriber from 0.3.18 to 0.3.19 by @dependabot in #1454
• Bump syn from 2.0.89 to 2.0.90 by @dependabot in #1453
• [ISSUE #1452]🔥Refactor rocketmq-remoting crate error handle🚨 by @mxsm in #1455
• [ISSUE #1456]🔥Refactor rocketmq-broker crate error handle🚨 by @mxsm in #1457
• [ISSUE #1458]🔥Refactor rocketmq-client crate error handle🚨 by @mxsm in #1459
• [ISSUE #1460]🔥Add macro for create client error🚀 by @mxsm in #1461
• [ISSUE #1463]🔥Add macro for create client RequestTimeout error🚀 by @mxsm in #1464
• [ISSUE #1462]🔥Add macro for create client broker error🚀 by @mxsm in #1465
• [ISSUE #1466]🔥Optimize mq_client_err! macro🚀 by @mxsm in #1467
• [ISSUE #1468]📝Update README.md🚀 by @mxsm in #1469
• [ISSUE #1471]🔥Clean test cases compile warning🚀 by @mxsm in #1472
• [ISSUE #1470]♻️FromMap trait from mehtod return type changed from OptionSelf::Target to ResultSelf::Target,Self::Error🚀 by @mxsm in #1473
• [ISSUE #1474]⚡Optimize derive RequestHeaderCodec and add required attribute🚀 by @mxsm in #1475
• [ISSUE #1476]♻️Refactor derive RequestHeaderCodec parse logic🔥 by @mxsm in #1478
• [ISSUE #1480]⚡️Optimize SendMessageProcessor error handle🔥 by @mxsm in #1481
• [ISSUE #1482]♻️Refactor create MQClientErr replace with mq_client_err! macro🔥 by @mxsm in #1483
• feat/91: Add get namesrv config request by @PanGan21 in #1485
• [ISSUE #1484]♻️Refactor create MQBrokerErr replace with client_broker_err! macro🔥 by @mxsm in #1486
• [ISSUE #1477]🚀derive RequestHeaderCodec support Struct🔥 by @mxsm in #1487
• [ISSUE #1489]📝Update rocketmq-macros README.md by @mxsm in #1490
• [ISSUE #1491]⚡️Add some comments for RequestHeaderCodec macor by @mxsm in #1492
• [ISSUE #1479]♻️Refactor CheckTransactionStateRequestHeader with derive RequestHeaderCodec🔥 by @mxsm in #1494
• [ISSUE #1496]♻️Refactor SendMessageRequestHeader with RequestHeaderCodec derive macro by @mxsm in #1497
• [ISSUE #1498]📝Update README.md by @mxsm in #1499
• [ISSUE #1500]♻️Refactor SendMessageRequestHeaderV2🍻 by @mxsm in #1501
• [ISSUE #1502]♻️Refactor PullMessageRequestHeader🍻 by @mxsm in #1504
• [ISSUE #1503]🍻Refactor PullMessageResponseHeader♻️ by @mxsm in #1506
• [ISSUE #1510]♻️Refactor GetBrokerMemberGroupRequestHeader with derive marco RequestHeaderCodec by @ButterflyEffect1991 in #1518
• [ISSUE #1495]🚀Optimize RemotingSerializable methods return type🔥 by @mxsm in #1517
• [ISSUE #1519] Replace SendMessageProcessor#process_request return type to crate::Result<Option> by @mxsm in #1520
• [ISSUE #1522]♻️Refactor UpdateConsumerOffsetRequestHeader with derive macro RequestHeaderCodec by @mxsm in #1523
• [ISSUE #1521]🔥Remove SendMessageRequestHeader queue_id Option🚀 by @TeslaRustor in #1524
• [ISSUE #1525]Optimization condition judgment by @what-design in #1526
• [ISSUE #1527]⚡️Optimize SendMessageProcessor handle error logic by @mxsm in #1528
• [ISSUE #1530]⚡️Optimize CommitLog put message logic by @mxsm in #1531
• Bump tokio from 1.41.1 to 1.42.0 by @dependabot in #1535
• Bump clap from 4.5.21 to 4.5.22 by @dependabot in #1534
• Bump anyhow from 1.0.93 to 1.0.94 by @dependabot in #1533
• [ISSUE #1536]📝Update README.md by @mxsm in #1537
• [ISSUE #1532]🚀Add support append enabled_append_prop_crc⚡️ by @mxsm in #1538
• [ISSUE #1539]🐛Fix cargo clippy -- -D warnings error by @mxsm in #1540
• [ISSUE #1542]♻️Refactor ConsumerSendMsgBackRequestHeader with derive RequestHeaderCodec🔥 by @mxsm in #1543
• [ISSUE #1544]🍻Add #[inline] for SubscriptionGroupConfig methods by @mxsm in #1545
• [ISSUE #1546]🚀Rocketmq-rust broker supports RequestCode ConsumerSendMsgBack(36)🔥 by @mxsm in #1547
• [ISSUE #1549]♻️Refactor GetRouteInfoRequestHeader with derive macro RequestHeaderCodec🔥 by @mxsm in #1550
• Bump tokio-util from 0.7.12 to 0.7.13 by @dependabot in #1555
• Bump sysinfo from 0.32.1 to 0.33.0 by @dependabot in #1554
• [ISSUE #1556]🔨Update Gtihub sync-issue-labels.yml action by @mxsm in #1557
• [ISSUE #1558]🚀Add error for rocketmq-namesrv by @mxsm in #1559
• [ISSUE #1552]⚡️Optimize ClientRequestProcessor error handle by @mxsm in #1560
• [ISSUE #1553]🔥Optimize rocketmq-namesrv crate DefaultRequestProcessor error handle⚡️ by @mxsm in #1561
• [ISSUE #1562]⚡️Optimize DefaultRequestProcessor error handle by @mxsm in #1563
• [ISSUE #1570]🚀Add ConsumeMessageDirectlyResultRequestHeader struct🔥 by @mxsm in #1571
• [ISSUE #1569]🔥Add GetConsumerRunningInfoRequestHeader struct🚀 by @mxsm in #1572
• [ISSUE #1568]🔥Add ResetOffsetRequestHeader struct🚀 by @mxsm in #1573
• [ISSUE #1567]🔥Add DeleteSubscriptionGroupRequestHeader struct🍻 by @mxsm in #1574
• [ISSUE #1566]🚀Add QueryConsumeTimeSpanRequestHeader struct🍻 by @mxsm in #1575
• [ISSUE #1565]🍻Add GetTopicStatsInfoRequestHeader struct 💡 by @mxsm in #1576
• [ISSUE #1577]🍻Replace ConsumeMessageDirectlyResultRequestHeader and ResetOffsetRequestHeader's RpcRequestHeader with TopicRequestHeader by @mxsm in #1578
• [ISSUE #1579]🐛get_topic_stats_info_request_header inner struct incorrect by @mxsm in #1580
• [ISSUE #1581]🚀Add QueueTimeSpan struct by @mxsm in #1582
• [ISSUE #1583]🍻Add QuerySubscriptionByConsumerRequestHeader struct by @mxsm in #1584
• [ISSUE #1564]🍻Add MqClientAdmin trait💡 by @mxsm in #1585
• [ISSUE #1529]Add #[inline] for MessageExtBrokerInner methods by @rust-learn-now in #1588
• [ISSUE #1586]📝Update rocketmq-client Cargo.toml🍻 by @mxsm in #1587
• [ISSUE #1507]♻️Refactor BrokerHeartbeatRequestHeader with derive marco RequestHeaderCodec by @Happy-debug-lang in #1589
• [ISSUE #1590]Add Label approved pull requests action by @rocketmq-rust-bot in #1591
• [ISSUE #1508]♻️Refactor UnRegisterBrokerRequestHeader with derive marco RequestHeaderCodec by @ButterflyEffect1991 in #1592
• Bump codecov/codecov-action from 5.0.7 to 5.1.1 by @dependabot in #1594
• Bump clap from 4.5.22 to 4.5.23 by @dependabot in #1593
• [ISSUE #1595]🔥Remove label_approved_pull_requests.yml action by @mxsm in #1596
• [ISSUE #1598]🚀Rocketmq-client support Pop consumer-1 by @mxsm in #1600
• [ISSUE #1601]Optimize PopProcessQueue by @mxsm in #1602
• [ISSUE #1603]Add #[inline] to PopProcessQueue method and optimize code by @mxsm in #1604
• [ISSUE #1605]🚀Add a pop consume example🔥 by @mxsm in #1606
• [ISSUE #1607]♻️Remove Rebalance trait useless method remove_unnecessary_pop_message_queue_pop🔥 by @mxsm in #1608
• [ISSUE #1599]🚀Rocketmq-client support Pop consumer-2📝 by @mxsm in #1609
• [ISSUE #1612]⚡️Optimize ConsumeMessageDirectlyResult struct🔥 by @mxsm in #1613
• [ISSUE #1611]🚀ClientRemotingProcessor supports RequestCode::ConsumeMessageDirectly(309)🔥 by @mxsm in #1614
• [ISSUE #1381]🚀Add GroupForbidden by @flydream-ylgw in #1621
• Bump tokio-stream from 0.1.16 to 0.1.17 by @dependabot in #1622
• [ISSUE #1615]Implement ConsumeMessageConcurrentlyService#consumeMessageDirectly by @universe-dota in #1623
• [ISSUE #1624]🚀Replace ClientRemotingProcessor's WeakArcMut with ArcMut🔥 by @mxsm in #1625
• [ISSUE #1509]Refactor BrokerHeartbeatRequestHeader with derive marco RequestHeaderCodec by @dream-cloud-fly in #1626
• [ISSUE #1616]🚀Implement ConsumeMessageOrderlyService#consumeMessageDirectly🔥 by @mxsm in #1628
• [ISSUE #1627]🚀Replace Client consumer's WeakArcMut with ArcMut🔥 by @mxsm in #1629
• [ISSUE #1617]🚀Implement ConsumeMessagePopConcurrentlyService#consumeMessageDirectly🔥 by @mxsm in #1630
• [ISSUE #1631]Remove useless code by @alax-cat in #1632
• [ISSUE #1618]🚀Implement ConsumeMessagePopOrderlyService#consumeMessageDirectly🔥 by @mxsm in #1633
• [ISSUE #1634]📝Add doc for ConsumeMessageServiceTrait trait🔥 by @mxsm in #1635
• [ISSUE #1378] Add BrokerStatsData by @sainad2222 in #1636
• [Issue #1295] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueByMachineRoom by @sainad2222 in #1641
• [ISSUE #1642]♻️Refactor AckMessageProcessor#process_request method signature🔥 by @mxsm in #1643
• [ISSUE #1644]♻️Refactor PollingInfoProcessor#process_request method signature🔥 by @mxsm in #1645
• [ISSUE #1646]♻️Refactor PeekMessageProcessor#process_request method signature🔥 by @mxsm in #1647
• [Issue #1292] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMachineRoomNearby by @sainad2222 in #1650
• [ISSUE #1649]🚀Implement ExtraInfoUtil for rust🔥 by @mxsm in #1652
• [Issue #1294] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueByConfig by @sainad2222 in #1651
• [ISSUE #1648]🚀Add ConsumeRequest for ConsumeMessagePopConcurrentlyService🔥 by @mxsm in #1654
• [ISSUE #1655]🚀Implement ConsumeMessagePopConcurrentlyService#process_consume_result logic🔥 by @mxsm in #1656
• [ISSUE #1659]🚀Add AckStatus enum🔥 by @mxsm in #1660
• [ISSUE #1658]🚀Add AckResult struct🔥 by @mxsm in #1661
• [ISSUE #1657]🚀Add AckCallback trait🔥 by @mxsm in #1662
• [ISSUE #1648]🚀Add ConsumeRequest for ConsumeMessagePopConcurrentlyService🔥 by @mxsm in #1663
• [ISSUE #1664]🚀Add ChangeInvisibleTimeRequestHeader struct🔥 by @mxsm in #1665
• [ISSUE #1664]🚀Add ChangeInvisibleTimeResponseHeader struct🔥 by @mxsm in #1668
• [ISSUE #1666]🚀Implement MQClientAPIImpl#changeInvisibleTimeAsync method logic🔥 by @mxsm in #1669
• [ISSUE #1670]🚀Implement DefaultMQPushConsumerImpl#change_pop_invisible_time_async method logic🔥 by @mxsm in #1672
• [ISSUE #1671]⚡️Optimize MQClientInstance#find_broker_address_in_subscribe method signature🔥 by @mxsm in #1673
• [ISSUE #1680]♻️Refactor ChangeInvisibleTimeProcessor handle logic🍻 by @mxsm in #1683
• [ISSUE #1679]🚀Add PopCheckPoint struct🍻 by @mxsm in #1682
• [ISSUE #1684]🧪Add unit test for PopAckConstants by @shadowsoy in #1686
• [ISSUE #1687]♻️Refactor PopMessageProcessor method handle error by @mxsm in #1688
• [ISSUE #1681]🚀Implement ChangeInvisibleTimeProcessor logic🍻 by @mxsm in #1690
• [ISSUE #1695]🍻Add EscapeBridge struct for rust🚀 by @mxsm in #1700
• [ISSUE #1696]🚀EscapeBridge supports putMessage🍻 by @mxsm in #1702
• [ISSUE #1689]Adding inline for PutMessageResult methods by @nakul-py in #1701
• Bump chrono from 0.4.38 to 0.4.39 by @dependabot in #1704
• [ISSUE #1705]♻️Refactor QueueFilter trait by @mxsm in #1706
• [ISSUE #1703]⚡️ Optimize TopicPublishInfo some method logic🔥 by @mxsm in #1707
• [ISSUE #1697]🚀EscapeBridge supports putMessageToRemoteBroker🔥 by @mxsm in #1708
• [ISSUE #1639] ⚡️ Add #[inline] for MessageClientExt struct method by @XmchxUp in #1710
• [ISSUE #1709]🚀Implement BrokerOuterAPI#send_message_to_specific_broker logic🔥 by @mxsm in #1712
• [ISSUE #1698]🚀EscapeBridge supports asyncPutMessage by @mxsm in #1713
• [ISSUE #1699]🚀EscapeBridge supports putMessageToSpecificQueue by @mxsm in #1715
• [ISSUE #1714]⚡️Add #[inline] for SendResult struct methods by @ad-source-bit in #1717
• [ISSUE #1718]📝Add rocektmq-rust icon by @mxsm in #1719
• [ISSUE #1694]🚀Rocketmq-broker supports EscapeBridge functions🔥 by @mxsm in #1716
• Bump serde from 1.0.215 to 1.0.216 by @dependabot in #1720
• [ISSUE #1721]⚡️Optimize EscapeBridge struct logic by @mxsm in #1722
• [ISSSUE #1723]🚀Add AckMsg struct🍻 by @mxsm in #1724
• [ISSUE #1725]🚀Add BatchAckMsg struct for rust✨ by @mxsm in #1726
• [ISSUE #1727]🍻Add PopBufferMergeService struct for rust 🚀 by @mxsm in #1728
• [ISSUE #1729]🚀Implement PopMessageProcessor static Method by @mxsm in #1731
• [ISSUE #1691]🍻Implement ChangeInvisibleTimeProcessor#ack_origin method🚀 by @mxsm in #1732
• [ISSUE #1730]⚡️Optimize Replace String with CheetahString in PopCheckPoint by @rust-learn-now in #1733
• [ISSUE #1692]🍻Implement ChangeInvisibleTimeProcessor#append_check_point method🚀 by @mxsm in #1734
• [ISSUE #1735]🚀Implement TimedLock function by @mxsm in #1736
• [ISSUE #1737]💥Implement QueueLockManager function🚀 by @mxsm in #1738
• [ISSUE #1693]🚀Implement ChangeInvisibleTimeProcessor#process_change_invisible_time_for_order method by @mxsm in #1740
• [ISSUE #1739]🚀Implement ConsumerOrderInfoManager#update_next_visible_time method logic by @mxsm in #1741
• [ISSUE #1742]⚡️Enhancement OrderInfo struct add some methods by @mxsm in #1744
• [ISSUE #1747]🤡Implement netty Timer for rust trait🚀 by @mxsm in #1750
• [ISSUE #1746]🍻Implement netty Timeout for rust trait🤡 by @mxsm in #1751
• [ISSUE #1752]📝Update Timer trait doc by @mxsm in #1753
• [ISSUE #1748]🚀Implement netty TimerTask for rust trait🔥 by @mxsm in #1754
• [ISSUE #1755]📝Update Github workflow action by @mxsm in #1756
• [ISSUE #1757]📝Update Github workflow action by @rocketmq-rust-robot in #1758
• [ISSUE #1759]🚀Implement netty HashedWheelTimeout for rust-1🔥 by @mxsm in #1761
• [ISSUE #1762]🚀Optimize ConsumerOrderInfoManager encode and decode🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1764
• [ISSUE #1763]🚀Implement ConsumerOrderInfoManager#auto_clean method function🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1765
• [ISSUE #1766]⚡️Replace ConsumerOrderInfoWrapper String with CheetahString🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1767
• [ISSUE #1768]📝Add Doc for RebalanceService struct🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1769
• [ISSUE #1770]🤡Optimize MQConsumerInnerImpl struct method logic🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1771
• [ISSUE #1773]🤡Optimize RebalanceImpl#try_query_assignment method logic and simply code🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1774
• [ISSUE #1775]🤡Simply MQClientInstance#query_assignment method code and add doc for method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1776
• [ISSUE #1777]🤡Optimize RebalanceImpl#get_rebalance_result_from_broker method and add doc for method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1778
• [ISSUE #1779]🤡Optimize RebalanceImpl#update_message_queue_assignment method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1780
• [ISSUE #1781]🤡Optimize RebalancePushImpl#dispatch_pop_pull_request logic🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1782
• [ISSUE #1783]🤡Optimize RebalancePushImpl#dispatch_pull_request unwrap logic🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1784
• Adding #[inline] for MQConsumerInnerImpl methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1787
• Adding #[inline] for PopRequest method by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1789
• [ISSUE #1791]🤡Add PopStatus struct for rust🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1792
• [ISSUE #1790]🤡Add PopResult struct for rust🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1793
• [ISSUE #1788]🤡Add PopCallback trait🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1794
• [ISSUE #1795]🤡Change PopCallback signature🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1796
• [ISSUE #1785]🤡Implement DefaultMQPushConsumerImpl#pop_message function🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1797
• [ISSUE #1798]🤡Optimize DefaultPullCallback#on_exception method code🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1799
• [ISSUE #1800]🤡Add PopMessageRequestHeader struct🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1801
• [ISSUE #1802]🤡Add PopMessageResponseHeader struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1803
• [ISSUE #1804]🚀Implement PullAPIWrapper#pop_async method logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1806
• [ISSUE #1805]🚀Implement MQClientAPIImpl#pop_message_async method logic🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1808
• [ISSUE #1743]Remove useless import in escape_bridge.rs test mode by @vagabond-0 in https://github.com/mxsm/rocketmq-rust/pull/1807
• [ISSUE #1809]🍻Implement MQClientAPIImpl#process_pop_response method logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1810
• [ISSUE #1811]🤡Implement DefaultMQPushConsumerImpl#process_pop_result method function🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1814
• [ISSUE #1815]🚀Implement ConsumeMessagePopServiceGeneral#submit_pop_co… by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1816
• [ISSUE #1817]🚀Implement ConsumeMessagePopConcurrentlyService#submit_pop_consume_request by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1819
• [ISSUE #1820]Add unsupport attention for submit_pop_consume_request by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1821
• [ISSUE #1822] ConsumeMessageServiceTrait trait provides default implementations of some methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1823
• [ISSUE #1818] Implement ConsumeMessagePopOrderlyService#submit_pop_consume_request by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1824
• [ISSUE #1825]🧑‍💻Add AckMessageRequestHeader for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1826
• [ISSUE #1813]🚀Implement DefaultMQPushConsumerImpl#ack_async method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1827
• [ISSUE #1830]🐰Add BatchAck struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1831
• [ISSUE #1829]🌽Add BatchAckMessageRequestBody struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1832
• [ISSUE #1833]🍓Replacing bit-vec crate with bitvec🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1834
• [ISSUE #1835]💡Remove Chinese comments from BatchAck📈 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1836
• [ISSUE #1828]🚀Implement MQClientAPIImpl#ackMessageAsync by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1837
• [ISSUE #1840]Add PopReviveService struce for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1841
• [ISSUE #1838]🚀AckMessageProcessor supports RequestCode AckMessage(200051) by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1842
• [ISSUE #1839]🚀AckMessageProcessor supports RequestCode BatchAckMessage(200051) by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1843
• [ISSUE #1845]🐛Fix Query assignment from broker clientId not correct🚑️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1846
• [ISSUE #1844]🚀Implement AckMessageProcessor#append_ack method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1847
• [ISSUE #1849]Add AckMessage trait for AckMsg and BatchAckMsg by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1850
• [ISSUE #1852]🧪Add test case for rebalance_strategy by @rust-learn-now in https://github.com/mxsm/rocketmq-rust/pull/1853
• [ISSUE #1855]🍓Optimize BatchAck BitSet like Java BitSet🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1856
• Bump codecov/codecov-action from 5.1.1 to 5.1.2 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1857
• [ISSUE #1858]⚡️AckMessage trait add get and set methods by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1859
• [ISSUE #1848]🔥Implement AckMessageProcessor#append_ack method-2 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1860
• [ISSUE #1812] ⚡️ Optimize PullResult msg_found_list with Option by @XmchxUp in https://github.com/mxsm/rocketmq-rust/pull/1861
• [ISSUE #1863]🔨Update auto-comment-pr.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1864
• [ISSUE #1867]🔨Update auto-comment-pr.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1868
• [ISSUE #1865]⚡️Adds a store_host attribute to BrokerRuntime struct by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1866
• [ISSUE #1862]🍻Implment PopInflightMessageCounter java for rust struct💡 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1869
• [ISSUE #1870]⚡️Replace other structs attribute store_host with BrokerRuntime store_host by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1871
• [ISSUE #1872]⚡️Optimize RunningFlags logic and add doc by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1873
• [ISSUE #1854]Remove mut for PopProcessQueue test case by @ad-source-bit in https://github.com/mxsm/rocketmq-rust/pull/1874
• [ISSUE #1637]Add #[inline] for Message struct method by @ButterflyEffect1991 in https://github.com/mxsm/rocketmq-rust/pull/1875
• [ISSUE #1876]⚡️Add #[inline] for DefaultMQProducerBuilder struct methods by @universe-dota in https://github.com/mxsm/rocketmq-rust/pull/1877
• [ISSUE #1878]🐛Fix data_version_next_version_with_state test case error sometime by @master-main-hub in https://github.com/mxsm/rocketmq-rust/pull/1879
• [ISSUE #1881]🚀Implement AckMessageProcessor#ackOrderly method logic by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1882
• [ISSUE #1883] Optimize RebalanceImpl#try_query_assignment performance by @rust-learn-now in https://github.com/mxsm/rocketmq-rust/pull/1884
• [ISSUE #1885]📝Add code comments for QueryAssignmentProcessor by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1886
• Bump bytemuck from 1.20.0 to 1.21.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1887
• [ISSUE #1888]📝Add cli ui resource🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1889
• [ISSUE #1890]🔖Replace ProcessQueue MessageClietExt with MessageExt🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1891
• [ISSUE #1893]🔖Implement ConsumeMessageServiceGeneral and ConsumeMessagePopServiceGeneral consume_message_directly method logic🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1894
• [ISSUE #1896]🔖Add PopLongPollingService struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1898
• [ISSUE #1422]Add TraceView struct for rust by @surajnuchin in https://github.com/mxsm/rocketmq-rust/pull/1900
• [ISSUE #1902]🔖Add SendMessageBackHook trait for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1903
• [ISSUE #1899]🚨PopMessageProcessor supports process_request handle🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1906
• [ISSUE #1908]🚨Add NotificationRequestHeader for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1909
• [ISSUE #1910]🚨Add clone derive for PopMessageRequestHeader struct🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1911
• [ISSUE #1907]🚨Add PollingHeader struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1912
• [ISSUE #1913]🚨Add PollingResult struct for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1914
• [ISSUE #1905]🚨PopMessageProcessor supports process_request handle-2🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1916
• [ISSUE #1901]⚡️Optimize MessageStore trait🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1918
• [ISSUE #1919]🚀Init rocketmq-tui crate by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1920
• [ISSUE #1921]⚡️Replace PopMessageProcessor Box with ExpressionMessageFilter by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1922
• [ISSUE #1923]🚀Implement PopMessageProcessor#readGetMessageResult by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1924
• [ISSUE #1925] Implement DefaultMQAdminExt#setMessageRequestMode by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1926
• [ISSUE #1928]⚡️Optimize AppendMessageStatus Display like Java AppendMessageStatus toString by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1930
• [ISSUE #1931]🚀Add PopRequest for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1932
• [ISSUE #1933]📱Update rocketmq-cli-ui.png and rocketmq-cli-ui.excalidraw by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1934
• [ISSUE #1935]🏗️Set up tui basic development framework🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1936
• Bump syn from 2.0.90 to 2.0.91 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1938
• Bump serde_json from 1.0.133 to 1.0.134 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1937
• [ISSUE #1927]Adding #[inline] for GetMessageResult's methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1940
• [ISSUE #1941]🚨Develop the component layout of the tui🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1942
• Add #[inline] for StoreStatsService methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1948
• Adding #[inline] for StoreCheckpoint methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1946
• [ISSUE #1943]Adding #[inline] for PutMessageContext's methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1944
• [ISSUE #1939]🔖PopMessageProcessor supports process_request handle-4🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1950
• [ISSUE #1951]📝Update rocketmq-tui crate README.md🔖 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1952
• [ISSUE #1954]Adding #[inline] for MappedFileQueue methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1955
• [ISSUE #1957]Adding #[inline] for IndexHeader methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1959
• [ISSUE #1956]Adding #[inline] for IndexFile methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1958
• Bump quote from 1.0.37 to 1.0.38 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1961
• Bump reqwest from 0.12.9 to 0.12.10 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1960
• [ISSUE #1970]🔖Fix cargo clippy -- -D warnings error🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1971
• Bump syn from 2.0.91 to 2.0.93 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1976
• Bump serde from 1.0.216 to 1.0.217 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1974
• Bump sysinfo from 0.33.0 to 0.33.1 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1973
• Bump reqwest from 0.12.10 to 0.12.11 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1972
• [ISSUE #1968]Adding #[inline] for AckMsg by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1969
• [ISSUE #1965]Adding #[inline] for DefaultMappedFile methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1966
• [ISSUE #1963]Adding #[inline] for IndexService methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/1964
• [ISSUE #1977]🔖Fix cargo clippy -- -D warnings error🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1978
• [ISSUE #1979]♻️Refactor ConsumerGroupInfo with dashmap🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1980
• [ISSUE #1949]♻️PopMessageProcessor supports process_request handle-5🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1981
• Bump reqwest from 0.12.11 to 0.12.12 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/1983
• [ISSUE #1984]♻️Develop SearchInputWidget for tui🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1985
• [ISSUE #1987]⚡️Remove useless crate from cargo.toml🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1988
• [ISSUE #1989]⚡️Add strum crate🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1990
• [ISSUE #1986]🍻Add Action for tui🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1991
• [ISSUE #1992]🍻Implement PopMessageProcessor#get_init_offset method logic🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1993
• [ISSUE #1994]🔨Update Github workflow action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1995
• [ISSUE #1998]🔨Update Github workflow action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1999
• [ISSUE #1996]🍻Implement PopMessageProcessor#reset_pop_offset method logic🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/1997
• [ISSUE #2000]🍻Implement PopMessageProcessor#queue_lock_manager🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2001
• [ISSUE #2002]🍻Add DataConverter for rust 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2003
• [ISSUE #2005]🍻Add PopCheckPointWrapper for PopBufferMergeService 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2006
• [ISSUE #2007]🍻Add QueueWithTime for PopBufferMergeService 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2008
• [ISSUE #2009]🔨Add Auto Approve Pull Requests workflow by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2010
• [ISSUE #2011]🐛Fix Add Auto Approve Pull Requests workflow token error by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2012
• [ISSUE #2013]🔨Optimize Auto Approve Pull Requests workflow by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2014
• [ISSUE #2016]🔨Optimize Auto Approve Pull Requests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2017
• [ISSUE #2018]🔨Optimize Auto Approve Pull Requests by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2019
• [ISSUE #2020]🔨Optimize Auto Approve Pull Requests by @SpaceXCN in https://github.com/mxsm/rocketmq-rust/pull/2021
• [ISSUE #1685] Add Channel's method #[inline] by @flydream-ylgw in https://github.com/mxsm/rocketmq-rust/pull/2015
• [ISSUE #2004]🍻Implement PopBufferMergeService-1 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2022
• Bump syn from 2.0.93 to 2.0.94 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2024
• [ISSUE #2026]♿️AckMessage extends std::fmt::Display by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2027
• [ISSUE #2025]⚗️Implement PopBufferMergeService#add_ack🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2028
• [ISSUE #2029]💫Implement PopBufferMergeService#get_latest_offset by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2030
• [ISSUE #2031]🚀Implement PopBufferMergeService#clear_offset_queue💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2032
• [ISSUE #2033]💫Move BrokerRole from store to common crate by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2034
• [ISSUE #2037]Adding #[inline] for BatchConsumeQueue methods. by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2039
• [ISSUE #2038]💫Implement PopBufferMergeService#start by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2040
• [ISSUE #2041]💫 Remove BrokerRole from rocketmq-store crate🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2042
• [ISSUE #2035] Add Apache License for broker.rs and compression.rs by @flydream-ylgw in https://github.com/mxsm/rocketmq-rust/pull/2044
• [ISSUE #2043]💫Implement PopBufferMergeService#scan🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2045
• [ISSUE #2047]🧐Implement PopMessageProcessor#buildCkMsg🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2048
• [ISSUE #2046]💫Implement PopBufferMergeService#putCkToStore🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2049
• [ISSUE #2050]💫Implement PopBufferMergeService#is_ck_done_for_finish by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2051
• [ISSUE #2052]💫Implement PopBufferMergeService#putAckToStore🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2053
• [ISSUE #2054]💫Optimize auto approve pull requests github action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2055
• [ISSUE #2056]💫Implement PopBufferMergeService#putBatchAckToStore for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2057
• [ISSUE #2058]💫Implement PopBufferMergeService scan_garbage and get_offset_total_size📸 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2059
• [ISSUE #2060]Adding #[inline] for ConsumeQueueStore methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2061
• [ISSUE #2062] Adding #[inline] for QueueOffsetOperator methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2063
• [ISSUE #2064]Adding #[inline] for ConsumeQueue methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2067
• [ISSUE #2066]💫Add ConsumeReviveObj struct🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2068
• [ISSUE #2069]💫Optimize auto approve pull requests github action by @flydream-ylgw in https://github.com/mxsm/rocketmq-rust/pull/2070
• [ISSUE #2065]💫Implement PopReviveService-1🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2072
• [ISSUE #2073]💫Implement PopReviveService#reviveRetry🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2074
• [ISSUE #2076]💫Implement PopReviveService#getMessage🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2077
• [ISSUE #2075]💫Implement PopReviveService#getReviveMessage🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2078
• [ISSUE #2079]💫Add HAConnectionRuntimeInfo for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2080
• [ISSUE #2081]💫Add HAClientRuntimeInfo for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2082
• [ISSUE #1382]💫Add HAClientRuntimeInfo for rust🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2084
• [ISSUE #2085]💫Implement PopReviveService#start🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2086
• [ISSUE #2087]🐛Fix ReferenceResource#hold not correct by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2088
• [ISSUE #2071]💫Implement PopReviveService-2⚗️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2089
• [ISSUE #2091] Adding #[inline] for BrokerStatsManager methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2092
• [ISSUE #2090]💫Implement PopReviveService#mergeAndRevive⚗️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2093
• [ISSUE #2094]💫Implement PopReviveService#rePutCK⚗️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2095
• [ISSUE #2097]💫Implement EscapeBridge#getMessageAsync⚗️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2098
• [ISSUE #2099]💫Refactor ReferenceResource⚗️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2100
• [ISSUE #2101]♻️Refactor DefaultMappedFile💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2102
• [ISSUE #2103]💫Add BrokerInner for BrokerRuntime🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2104
• [ISSUE #2105]💫Add NameServerRuntimeInner for NameServerRuntime 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2106
• [ISSUE #2109]💫Refactor name server crate with NameServerRuntimeInner♻️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2110
• [ISSUE #2107]Adding #[inline] for RunningFlags methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2108
• [ISSUE #2111]🏗️BrokerInner add mut methods⚡️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2112
• [ISSUE #2113]💫Implement BrokerOuterAPI#pullMessageFromSpecificBrokerAsync🥅 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2114
• [Issue 2117] Fix unused warnings in RocketMQ examples by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2118
• [ISSUE #2119]💫Add ConsumeQueueData for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2120
• [ISSUE #1380]💫Add QueryConsumeQueueResponseBody by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2121
• [ISSUE #2122]💫Add BrokerOperatorResult for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2123
• [ISSUE #2124]💫Add RollbackStats for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2125
• [ISSUE #2115]Allow unused imports in ordermessage_consumer file by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2116
• [ISSUE #2126]💫Optimize RegisterBrokerBody filter_server_list Vec with Vec🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2127
• [ISSUE #2130]📝Add doc for RouteInfoManager🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2131
• Bump syn from 2.0.94 to 2.0.95 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2132
• [ISSUE #1512]♻️Refactor PutKVConfigRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2133
• [ISSUE #2134]🐛Fix get_kv_config return code not correct by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2136
• [ISSUE #2135]📝Update Issues template by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2137
• [ISSUE #1513]♻️Refactor GetKVConfigRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2138
• [ISSUE #1514]♻️Refactor GetKVConfigResponseHeader with derive marco R… by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2139
• [ISSUE #1515]♻️Refactor DeleteKVConfigRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2140
• [ISSUE #2141]♻️Refactor QueryDataVersionRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2142
• [ISSUE #2143]♻️Refactor QueryDataVersionResponseHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2144
• [ISSUE #2145]💫Optimize DefaultRequestProcessor check_sum_crc32 method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2146
• [ISSUE #2147]💫Optimize DefaultRequestProcessor extract_register_topic_config_from_request by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2148
• [ISSUE #2149]♻️Refactor RegisterBrokerRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2150
• [ISSUE #2151]♻️Refactor RegisterBrokerResponseHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2152
• [ISSUE #2153]⚡️Reduce memory copy in process_register_broker method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2154
• [ISSUE #2155]♻️Refactor WipeWritePermOfBrokerRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2156
• [ISSUE #2157]🔨Update auto approve pull requests wait time by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2158
• Bump serde_json from 1.0.134 to 1.0.135 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2159
• Bump clap from 4.5.23 to 4.5.24 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2160
• [ISSUE #2161]🚀Implement BatchUnregistrationService💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2162
• [ISSUE #2163]⚡️Nameserver supports batch broker unregistration by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2164
• [ISSUE #1516]♻️Refactor GetKVListByNamespaceRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2165
• [ISSUE #2166]♻️Refactor DeleteTopicFromNamesrvRequestHeader and RegisterTopicRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2167
• [ISSUE #2168]♻️Refactor GetTopicsByClusterRequestHeader and TopicRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2169
• [ISSUE #2170]🐛Fix BatchUnregistrationService not started when Name server start by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2171
• [ISSUE #2172]🤡Implement name server graceful shutdown⚡️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2173
• Bump tokio from 1.42.0 to 1.43.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2175
• [ISSUE #2174]♻️Refactor remoting graceful shutdown by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2176
• [ISSUE #2177]⚡️Optimize name server graceful shutdown by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2178
• [ISSUE #2179]💫Optimize RouteInfoManager#un_register_broker method🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2180
• Bump clap from 4.5.24 to 4.5.26 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2183
• [ISSUE #2181]💫Optimize RouteInfoManager#clean_topic_by_un_register_requests🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2182
• [ISSUE #2184]⚡️Optimize RouteInfoManager#choose_broker_addrs_to_notify by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2185
• [ISSUE #2186]♻️Refactor MQClientManager💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2187
• [ISSUE #2188]💫Remove SyncUnsafeCellWrapper from mmapped_file🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2189
• [ISSUE #2190]💫Add MappedFileRefactor trait🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2191
• [ISSUE #2192]💫ADefaultMappedFile implement rename_to🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2193
• Bump uuid from 1.11.0 to 1.11.1 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2194
• Bump syn from 2.0.95 to 2.0.96 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2195
• Bump log from 0.4.22 to 0.4.24 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2196
• [ISSUE #2197]💫Replace MappedFile#is_full Ordering::Relaxed with Ordering::Acquire🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2198
• [ISSUE #2199]💫Implement MappedFile append_message_bytes and append_message_with_offset🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2200
• [ISSUE #2201]💫Optimize DefaultMappedFile#flush🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2202
• [ISSUE #2205]🐛Fix stats_item.rs cargo clippy -- -D warnings error🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2206
• [ISSUE #2203]💫Implement select_mapped_buffer and select_mapped_buffer_with_position method🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2204
• [ISSUE #2207]🚸Add Default trait for SelectMappedBufferResult🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2208
• [ISSUE #2209]🚸Implement DefaultMappedFile#get_mapped_byte_buffer🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2210
• [ISSUE #2211]🚨Implement DefaultMappedFile get_last_modified_timestamp and slice_byte_buffer🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2212
• [ISSUE #2213]🚨Refactor DefaultMappedFile#get_data🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2214
• [ISSUE #2215]🚨Implement DefaultMappedFile#destroy🍻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2216
• [ISSUE #2217]💫Refactor Broker crate with BrokerRuntimeInner♻️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2218
• [ISSUE #2129]💫Remove KVConfigManager #[derive(Clone)]🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2219
• [ISSUE #2128]💫Remove RouteInfoManager #[derive(Clone)]🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2220
• [ISSUE #2221]💫Optimize BrokerRuntimeInner#register_increment_broker_data🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2222
• [ISSUE #2223]💫Remove BrokerRuntime unused code and enhancement code🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2224
• [ISSUE #2225]📌Remove BrokerRuntime #[derive(Clone)] ⚡️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2226
• [ISSUE #2227]💫Implement broker graceful shutdown🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2228
• Bump proc-macro2 from 1.0.92 to 1.0.93 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2229
• [ISSUE #2230]💫Implement BrokerOuterAPI#unregisterBrokerAll🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2231
• [ISSUE #2232]🐛Fix Boker shutdown maybe register again by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2233
• [ISSUE #2234]⚡️Optimize BrokerRuntimeInner register_broker_all method paramters🦺 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2235
• [ISSUE #2236]💫BrokerRuntime implement unregister broker🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2237
• [ISSUE #2238]💫Change the default value of total_replicas from 0 to 1 in the message_store_config🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2239
• Bump uuid from 1.11.1 to 1.12.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2240
• Bump log from 0.4.24 to 0.4.25 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2241
• [ISSUE #2247]🚀 TopicQueueMappingCleanService and BroadcastOffsetManager add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2248
• [ISSUE #2245]🚀TimerMessageStore add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2246
• [ISSUE #2243]🚀ReplicasManager add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2244
• [ISSUE #2251]🚀NotificationProcessor and PopMessageProcessor add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2252
• [ISSUE #2249]🚀AckMessageProcessor and BrokerStatsManager add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2250
• [ISSUE #2253]⚡️Change ConsumerManager signature of new method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2254
• [ISSUE #2255]🚀Add BrokerFastFailure struct for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2256
• [ISSUE #2257]🚀Add BrokerPreOnlineService struct for rust by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2258
• [ISSUE #2259] 🚀TransactionMetricsFlushService and TransactionalMessageCheckService add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2260
• [ISSUE #2261]🚀ColdDataCgCtrService and ColdDataPullRequestHoldService add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2262
• [ISSUE #2263]🚀DefaultTransactionalMessageService and EscapeBridge add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2264
• [ISSUE #2265]🚀ScheduleMessageService and TopicRouteInfoManager add shutdown method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2266
• [ISSUE #2242]🚀Optimize BrokerRuntime shutdown💥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2267
• [ISSUE #2268]💫Optimize BrokerRuntime start method🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2272
• [ISSUE #1851]Adding #[inline] for QueryResult methods by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2269
• [ISSUE #2270]Adding #[inline] for ClientConfig methods. by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2271
• [ISSUE #2273]🏗️Optimize BrokerRuntime message_store start make it stronger by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2274
• [ISSUE #2275]🔥Remove rocketmq-store log crate by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2276
• [ISSUE #2277]🚀AckMessageProcessor and BroadcastOffsetManager add start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2278
• [ISSUE #2281]🚀BrokerStatsManager and ColdDataCgCtrService add start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2282
• [ISSUE #2279]🚀BrokerFastFailure and BrokerPreOnlineService add start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2280
• [ISSUE #2281]🚀BrokerStatsManager and ColdDataCgCtrService add start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2284
• [ISSUE #2285]🚀 PopMessageProcessor,TimerMessageStore and TopicQueueMappingCleanService add start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2286
• [ISSUE #2287]🚀Implement BrokerRuntime start method💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2288
• [ISSUE #2289]🤡Add PopConsumer for example🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2290
• [ISSUE #2291]🙈Change QueryAssignmentProcessor process_request method return paramter⚡️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2292
• [ISSUE #2293]🤡Remove MessageRequestModeManager#set_message_request_mode clone⚡️ by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2294
• Bump thiserror from 1.0.69 to 2.0.11 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2295
• [ISSUE #2296]📝Add comment for RebalancePushImpl#client_rebalance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2297
• [ISSUE #2298]⚡️Remove PopMessageProcessor useless code by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2299
• [ISSUE #2300]🚀Implement PopMessageProcessor start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2301
• [ISSUE #2302]⚡️Optimize PopMessageProcessor#process_request by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2303
• [ISSUE #2304]🏗️Add RemotingCommand encodeHeader method for Zero Copy🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2305
• [ISSUE #2306]⚡️Remove useless set_cmd_version from RemotingCommand by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2307
• [ISSUE #2308]🚀Add some method for SelectMappedBufferResult by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2309
• [ISSUE #2310]🚀Implement MappedFile isLoaded method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2311
• [ISSUE #2312]Adding #[inline] for CountDownLatch methods. by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2313
• [ISSUE #2314]Add License header for NotifyMinBrokerIdChangeRequestHeader by @flydream-ylgw in https://github.com/mxsm/rocketmq-rust/pull/2315
• [ISSUE #1511]♻️Refactor NotifyMinBrokerIdChangeRequestHeader with derive marco RequestHeaderCodec by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2316
• [ISSUE #2317]🤡Remove broker crate dependeces of log crate🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2318
• [ISSUE #2319]🤡Add README.md for broker-store crate🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2320
• [ISSUE #2321]🤡Remove useless code from PullMessageProcessor🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2322
• [ISSUE #2323]🐛Fix PopMessageProcessor build SubscriptionData error🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2324
• [ISSUE #2325]🐛 Fix build SubscriptionData with ExpressionType::TAG🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2326
• [ISSUE #2327]🤡SelectMappedBufferResult add bytes attribute🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2328
• [ISSUE #2329]🤡Complete the PopMessageProcessor process_request processing logic🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2330
• [ISSUE #2331]🤡Remove PopBufferMergeService useless code🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2332
• [ISSUE #2333]🤡Implement PopBufferMergeService addCkMock method🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2334
• [ISSUE #2336]🤡Implement PopLongPollingService notifyMessageArriving🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2337
• [ISSUE #2341]🤡Add ReplicaIdentity for rust🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2342
• [ISSUE #2340]🤡Add ReplicasInfo for rust🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2343
• [ISSUE #2339]🤡Add BrokerReplicasInfo for rust🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2344
• [ISSUE #2345]🐛Fix broker start error by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2346
• [ISSUE #2347]🐛Fix PopBufferMergeService run too faster by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2348
• [ISSUE #2350]🚀Add CompositeCodec for send bytes by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2351
• [ISSUE #2349]🤡Connection supports send bytes 🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2352
• Bump serde_json from 1.0.135 to 1.0.137 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2354
• Bump clap from 4.5.26 to 4.5.27 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2355
• [ISSUE #2353]⚡️Optimize Connection#send_command performance by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2356
• [ISSUE #2357]🤡Use RemotingCommand take_body method for performance🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2358
• Bump uuid from 1.12.0 to 1.12.1 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2359
• [ISSUE #2360]🚀Implement PopLongPollingService polling by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2361
• [ISSUE #2362]💫Implement PopLongPollingService wake_up🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2363
• [ISSUE #2369]🤡Optimize ConnectionHandlerContext replace WeakArcMut with ArcMut🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2370
• [ISSUE #2369]🤡Optimize ConnectionHandlerContext replace WeakArcMut with ArcMut🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2371
• [ISSUE #2364]🚀PopRequest implement get_channel and get_channel_mut method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2365
• Add GetMetaDataResponseHeader and ElectMasterResponseHeader by @0xfffb in https://github.com/mxsm/rocketmq-rust/pull/2366
• [ISSUE #2372]👻Channel add send method🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2373
• [ISSUE #2374]♻️Replace PopMessageProcessor new with new_arc_mut by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2375
• [ISSUE #2376]🚀Implement BrokerOuterAPI shutdown by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2377
• [ISSUE #2378]🔥Implement RocketmqDefaultClient shutdown method🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2379
• [ISSUE #2367]Adding #[inline] for all implemented methods in bootstrap.rs by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2368
• [ISSUE #2380]🤡Implement PopLongPollingService start🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2381
• [ISSUE #2382]🤡Optimize PopLongPollingService polling_map map performance🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2383
• [ISSUE #2384]🚀Implement PopMessageProcessor shutdown🤡 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2385
• [ISSUE #2386]🔍️Optimize Connection#send_command performance 🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2387
• [ISSUE #2388]Fix PopMessageProcessor popMsgFromQueue bug by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2389
• [ISSUE #2390]🤡Implement PopMessageProcessor is_pop_should_stop method🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2391
• [ISSUE #2392]💫Implement QueueWithTime thread sync safety🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2393
• [ISSUE #2394]🐛Fix PopBufferMergeService get_latest_offset queue back None by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2395
• [ISSUE #2396]🚀RocketMQMessageStore add get_message_with_total_size method🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2397
• [ISSUE #2398]🐛Fix GetMessageStatus judgement not incorret by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2399
• [ISSUE #2400]🤡Optimize PopMessageProcessor pop_msg_from_queue method🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2401
• [ISSUE #2402]🤡Implement PopBufferMergeService addCkMock method🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2403
• [ISSUE #2404]🤡Add transfer_msg_by_heap judgement for PopMessageProcessor in _process_request🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2405
• [ISSUE #2338]🤡Add RequestTask for rust🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2406
• [ISSUE #2408]🤡Remove AckMessageProcessor useless code🧑‍💻 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2409
• [ISSUE #2412]♻️Refactor PopReviveService🤡 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2413
• [ISSUE #2410]Implement AckMessageProcessor start method by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2415
• [Enhancement⚡️] Modify PullResult pub to pub(crate) and add #[inline] to methods by @0xfffb in https://github.com/mxsm/rocketmq-rust/pull/2414
• [Enhancement⚡️] Replace SendResult String with CheetahString by @0xfffb in https://github.com/mxsm/rocketmq-rust/pull/2416
• refactor: reference parameters for MessageListenerOrderlyFn by @0xfffb in https://github.com/mxsm/rocketmq-rust/pull/2417
• [ISSUE #1929] Optimize PutMessageStatus Display like Java PutMessageStatus toString by @yuz10 in https://github.com/mxsm/rocketmq-rust/pull/2418
• [ISSUE #2419] Adding #[inline] for RocketMQRuntime method by @nakul-py in https://github.com/mxsm/rocketmq-rust/pull/2420
• [ISSUE #1379] Add ConsumeStatsList by @yuz10 in https://github.com/mxsm/rocketmq-rust/pull/2422
• [ISSUE #1676] Optimize MessageListenerConcurrentlyFn signature by @yuz10 in https://github.com/mxsm/rocketmq-rust/pull/2423
• Bump serde_json from 1.0.137 to 1.0.138 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2426
• Bump tempfile from 3.15.0 to 3.16.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2427
• [ISSUE #2430]🐛Fix cargo clippy -- -D warnings error by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2431
• [ISSUE #2428]🌐Add rocketmq doc site🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2429
• [ISSUE #2432]Create jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2433
• [ISSUE #2434]🔨Fix jekyll-gh-pages.yml action error by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2435
• [ISSUE #2436]Update google_site_verification for rocketmq doc by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2437
• [ISSUE #2438]Add google site verification by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2439
• [ISSUE #2440]Add algolia support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2441
• [ISSUE #2442]Add algolia support by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2443
• [ISSUE #2444]⚡️Update algolia index by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2445
• [ISSUE #2446]📝Add Contributor Guide doc by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2447
• [ISSUE #2448]Update codecov.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2449
• [ISSUE #2424]Bump rand from 0.8.5 to 0.9.0 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2425
• [ISSUE #2450]Add Algolia Crawler Github Action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2451
• [ISSUE #2452]Update Add Algolia Crawler Github Action crawler-name by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2453
• [ISSUE #2411]💫Implement AckMessageProcessor shutdown method🥅 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2454
• [ISSUE #2455]💫Add print string for AckMessageProcessor handle code not supporting🥅 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2456
• [ISSUE #2457]💫Optimize AckMessageProcessor handle ack message🥅 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2458
• [ISSUE #2459]💫update doc image🥅 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2460
• [ISSUE #2461]📝Add Architecture doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2462
• [ISSUE #2463]🔨Update jekyll-gh-pages.yml action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2464
• [ISSUE #2465]🔨Update jekyll-gh-pages.yml action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2466
• [ISSUE #2467]🔨Update jekyll-gh-pages.yml action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2468
• [ISSUE #2469]Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2470
• [ISSUE #2471]📝Add what is rocketmq-rust doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2472
• [ISSUE #2473]🔨Update Algolia crawler name by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2474
• [ISSUE #2475]📝Add Components doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2476
• [ISSUE #2477] Update jekyll-gh-pages.yml action by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2478
• [ISSUE #2479]📝Add Run RocketMQ Rust locally doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2480
• [ISSUE #2482]🔨Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2483
• [ISSUE #2481]📝Add Run RocketMQ Rust with Docker doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2484
• Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2486
• [ISSUE #2485]📝Add Run RocketMQ with Kubernetes doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2487
• Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2488
• [ISSUE #2489]📝Update algolia index name💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2490
• Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2491
• Update jekyll-gh-pages.yml by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2492
• [ISSUE #2493]📝Add rocketmq-rust architecture💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2494
• [ISSUE #2495]📝Add rocketmq-rust architecture to home page💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2496
• [ISSUE #2497]📝Add What’s Rocketmq Rust doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2498
• [ISSUE #2499]📝Update What’s Rocketmq Rust doc zh path💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2500
• [ISSUE #2501]📝Typo Contribute Guide doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2502
• [ISSUE #2504]🔥Enhancement AckMessageProcessor ack_orderly💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2505
• [ISSUE #2506]🔥Implement PopMessageProcessor notify_message_arriving method💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2507
• [ISSUE #2508]🔥Fix PopLongPollingService notify_message_arriving is none unwrap💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2509
• [ISSUE #2510]🔥Add Rocketmq Rust Components doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2511
• Bump clap from 4.5.27 to 4.5.28 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2514
• Bump bytes from 1.9.0 to 1.10.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2515
• Bump syn from 2.0.96 to 2.0.98 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2516
• [ISSUE #2513]🔥Add Release doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2517
• Bump openssl from 0.10.69 to 0.10.70 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2518
• [ISSUE #2519]🔥Add Roadmap doc💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2520
• [ISSUE #2521]🔥Add header image for posts💫 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2522
• [ISSUE #2521]📝Update README.md🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2523
• [ISSUE #2524]📝Update website doc🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2525
• Bump uuid from 1.12.1 to 1.13.1 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2528
• [ISSUE #2526] Remove ConsumerManageProcessor unused code by @siddheshzz in https://github.com/mxsm/rocketmq-rust/pull/2529
• Bump once_cell from 1.20.2 to 1.20.3 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2530
• [ISSUE #2531]⚡️Optimize QueryAssignmentProcessor do_load_balance🚀 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2532
• Bump tabled from 0.17.0 to 0.18.0 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2533
• [ISSUE #2534]🚀Optimize PopMessageProcessor some code🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2535
• [ISSUE #2536]🚀 Implement ExpressionMessageFilter is_matched_by_commit_log method 🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2537
• [ISSUE #2527]Remove ClientManageProcessor unused code by @decadezzz in https://github.com/mxsm/rocketmq-rust/pull/2538
• [ISSUE #2539]🚀Replace DefaultMappedFile get_committed_position load with Ordering::Relaxed to Ordering::Acquire 🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2540
• Bump clap from 4.5.28 to 4.5.29 by @dependabot in https://github.com/mxsm/rocketmq-rust/pull/2541
• [ISSUE #2542]🔨Update package_publish_workspace.sh🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2543
• [ISSUE #2544]🔨Update package_publish_workspace.bat 🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2545
• [ISSUE #2546]🔨Fix package_publish_workspace.bat error🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2547
• [ISSUE #2548]🚀 DefaultMQAdminExt add create instance method🚧 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2549
• [ISSUE #2550]🚀Implement DefaultMQAdminExt start method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2551
• [ISSUE #2552]🚀Implement DefaultMQAdminExt shutdown method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2553
• [ISSUE #2554]🚀Fix pop consumer can't start🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2555
• [ISSUE #2556]🚀Implement DefaultMQAdminExt examine_topic_route_info method🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2557
• [ISSUE #2558]🚀Remove MQAdminExtInnerImpl start and shutdown🔥 by @mxsm in https://github.com/mxsm/rocketmq-rust/pull/2559

New Contributors

• @rocketmq-rust-robot made their first contribution in #1314
• @PanGan21 made their first contribution in #1316
• @Happy-debug-lang made their first contribution in #1589
• @sainad2222 made their first contribution in #1636
• @nakul-py made their first contribution in #1701
• @XmchxUp made their first contribution in #1710
• @ad-source-bit made their first contribution in #1717
• @vagabond-0 made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/1807
• @surajnuchin made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/1900
• @0xfffb made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/2366
• @yuz10 made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/2418
• @siddheshzz made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/2529
• @decadezzz made their first contribution in https://github.com/mxsm/rocketmq-rust/pull/2538

Full Changelog: v0.3.0...v0.4.0