## mxsm/rocketmq-rust — v0.4.0…v0.5.0 _371+ commits._ ### Features - **[ISSUE #3264]🚀RequestCode enum add more request code (#3265)** (d602b0e) - **[ISSUE #3248]📝Add DeepWiki badge (#3249)** (edc5f23) - **[ISSUE #3224]⚡️Add rocketmq-rust logo (#3225)** (cc9fc88) - **[ISSUE #3222]⚡️Add rocketmq-rust logo (#3223)** (5746edc) - **[ISSUE #3018]⚡️Add #[inline] for PermName's methods (#3210)** (36cf2a0) - **[ISSUE #3204]🚀Optimize ValidateTopicResult add take_remark method (#3205)** (15fe179) - **[ISSUE #3200]🚀Add Slot struct for Timer message (#3201)** (b17f623) - **[ISSUE #3190]🚀BrokerRutime message store add CommitLogDispatcherCalcBitMap (#3191)** (a5fc999) - **[ISSUE #3152]🚀Add comments for PopBufferMergeService (#3153)** (677daa7) - **[ISSUE #3138]⚡️Optimize AckMessageProcessor#append_ack code and add comments (#3139)** (d75e220) - **[ISSUE #3136]📝Add comments for ConsumerOffsetManager attribute (#3137)** (299cba5) - **[ISSUE #3127]⚡️Set PopReviveService ShouldRunPopRevive on new (#3128)** (f96e5ae) - **[ISSUE #3057]🚀Add ChannelEventListener implement for Remoting (#3126)** (ebe01c7) - **[ISSUE #3114]🚀Add ProducerTableInfo struct (#3116)** (168d394) - **[ISSUE #3113]🚀Add ProducerInfo struct (#3115)** (841cf03) - **[ISSUE #3107]🔨Add rocketmq-error crate for package script💫 (#3108)** (06cc304) - **[ISSUE #3105]🚀Add rocketmq-error crate💫 (#3106)** (8e3505c) - **[ISSUE #3101]🚀Add BrokerHousekeepingService for name server crate 💫 (#3104)** (5291a39) - **[ISSUE #3102]🚀Add client_housekeeping_service for broker💫 (#3103)** (d3c9906) - **[ISSUE #3099]🚀Add TokioEvent struct 💫 (#3100)** (c0cceb2) - **[ISSUE #3089]⚡️ProducerManager add some attrutes (#3090)** (abf247c) - **[ISSUE #3086]🚀Add ProducerChangeListener trait (#3087)** (5335d4c) - **[ISSUE #3084]🚀Add ProducerGroupEvent enum (#3085)** (99dc1ba) - **[ISSUE #3080]🚀Add ClientHousekeepingService (#3081)** (2312ba8) - **[ISSUE #3060]🚀Add ChannelEventListener for ConnectionListener (#3061)** (3a23259) - **[ISSUE #3058]🚀Add ChannelEventListener trait for Remoting (#3059)** (0d5b481) - **[ISSUE #3035]🚀DefaultMappedFile add file mapped bytes (#3036)** (f54382f) - **[ISSUE #3033]🚀Connection add send_bytes and send_slice methods (#3034)** (b53164b) - **[ISSUE #3021]📝Add comments for PopMessageProcessor#_process_request (#3022)** (bb8c225) - **[ISSUE #3012]📝Add doc for QueryAssignmentProcessor💫 (#3013)** (0fd9a2f) - **[ISSUE #3010]📝Add doc for get_message_request_mode_path method💫 (#3011)** (c3743ba) - **Revert "[ISSUE #3004]🚀Add rocketmq-rust-site submodule💫 (#3005)" (#3007)** (108456d) - **[ISSUE #3004]🚀Add rocketmq-rust-site submodule💫 (#3005)** (0af36e8) - **[ISSUE #3002]🚀Add file appender for log💫 (#3003)** (d15137b) - **[ISSUE #2983]🚀Support CQType::RocksDBCQ create ConsumeQueue (#2984)** (15fc668) ### Fixes - **[ISSUE #3280]⚡️Fix cargo clippy -- -D warnings error (#3281)** (e99863b) - **[ISSUE #3252]🐛Fix DefaultMappedFile Dangling Reference issue (#3253)** (862897f) - **[ISSUE #3229]🐛Fix Broker can not startup due to ConsumeQueueStore#check_self (#3230)** (848844b) - **[ISSUE #3129]🐛Fix ExtraInfoUtil split not correct (#3130)** (8f1ddec) - **[ISSUE #3008]🐛Fix file appender can not working💫 (#3009)** (7da9c6b) ### Backend - **[ISSUE #3279]📝Documentation Related ：Update Feature list in rocketmq-broker README.md (#3276)** (0bcde60) - **[Doc📝] Documentation Related ：Update Feature list in rocketmq-broker README.md (#3275)** (83d6904) - **[ISSUE #2716]🚀Implement NotificationProcessor acording to Java code (#3245)** (ad87b8f) - **Bump sysinfo from 0.35.0 to 0.35.1 (#3271)** (3c46c50) - **Bump tempfile from 3.19.1 to 3.20.0 (#3272)** (5c260e1) - **Bump clap from 4.5.37 to 4.5.38 (#3270)** (8839c4a) - **[ISSUE #3269]⚡️Optimize use of unstable library feature duration_constructors_lite (#3273)** (a6b7703) - **[ISSUE #3267]♻️Refactor PutMessageHook trait (#3268)** (dda3459) - **[ISSUE #3260]📝Remove Associate Milestone action (#3261)** (7837019) - **[ISSUE #3258]⚡️Optimize TopicQueueLock (#3259)** (80dd53a) - **[ISSUE #3256]⚡️Optimize PutMessageThreadLocal performance (#3257)** (1cce0a1) - **[ISSUE #3254]⚡️Optimize ArcMut (#3255)** (5e68120) - **[ISSUE #3250]⚡️Replace MessageIdSupplier Box with Arc (#3251)** (db342f4) - **[ISSUE #3246]⚡️Optimize MessageExtEncoder performance (#3247)** (51d77de) - **[ISSUE #2794]Improve KVConfigManager perfermance with DashHashp (#3240)** (c2c28da) - **[ISSUE #3243]📝Update README.md (#3244)** (2bc0007) - **[ISSUE #3241]📝Update READM.md (#3242)** (d2552ec) - **Bump tokio from 1.44.2 to 1.45.0 (#3239)** (8f9638f) - **[ISSUE #3237]⚡️Optimize SendMessageProcessor send_message (#3238)** (8723421) - **[ISSUE #3236]Optimize Code Format (#3235)** (df39d55) - **[ISSUE #3233]⚡️Optimize LocalFileMessageStore put_message_hook_list attribute (#3234)** (740750e) - **[ISSUE #3231]🚀Implement ConsumeQueue#check_self (#3232)** (6ad8590) - **[ISSUE #3227]♻️Refactor SendMessageProcessor handle_put_message_result (#3228)** (f3a4aaf) - **[ISSUE #3221]📝Update README.md (#3226)** (74251f5) - **[ISSUE #3216]⚡️Implement BrokerRuntime#register_increment_broker_data (#3219)** (43e0d24) - **[ISSUE #2933]♻️Refactor AddWritePermOfBrokerRequestHeader with derive marco RequestHeaderCodec (#3218)** (e3b4f06) - **[ISSUE #3215]⚡️Implement BrokerRuntime#register_increment_broker_data (#3217)** (b139ba7) - **[ISSUE #2932]♻️Refactor WipeWritePermOfBrokerResponseHeader with derive marco RequestHeaderCodec (#3214)** (bca313a) - **[ISSUE #2704]⚡️Optimize broker_bootstrap_server log init (#3213)** (4fb4259) - **[ISSUE #3211]⚡️Optimize TopicConfigManager#init method (#3212)** (c070bbf) - **[ISSUE #3208]⚡️Optimize TopicValidator (#3209)** (e37b02e) - **[ISSUE #3206]⚡️Remove use lazy_static::lazy_static in TopicAttributes (#3207)** (748766d) - **[ISSUE #3202]🚀Optimize SendMessageProcessor code (#3203)** (d9e42e5) - **[ISSUE #3198]🚀Implement ConsumeQueueStore#check_self (#3199)** (aaaf134) - **[ISSUE #3196]🚀Implement ConsumeQueueStore recover_concurrently (#3197)** (59c6470) - **[ISSUE #3194]🚀Optimize Borker code (#3195)** (8bb8956) - **[ISSUE #3192]🚀Replace MessageStoreConfig and ServerConfig with Arc in BrokerRuntime (#3193)** (cfc612f) - **[ISSUE #3187]🚀Implement CommitLogDispatcherCalcBitMap (#3189)** (01115e3) - **Bump sysinfo from 0.34.2 to 0.35.0 (#3186)** (28ca2a3) - **[ISSUE #3183]🚀Implement LocalFileMessageStore get_dispatcher_list and add_dispatcher methods (#3184)** (4389463) - **[ISSUE #3181]⚡️Remove BrokerRuntime useless code (#3182)** (06bebe0) - **[ISSUE #3179]⚡️Optimize ScheduleMessageService (#3180)** (34fb99f) - **[ISSUE #3177]🚀Implement NotificationProcessor start and shutdown (#3178)** (ce051ac) - **[ISSUE #3166]📝Update README.md (#3176)** (3005b0a) - **Bump tabled from 0.18.0 to 0.19.0 (#3163)** (c9558fd) - **Bump syn from 2.0.100 to 2.0.101 (#3171)** (179bfb3) - **Bump local-ip-address from 0.6.3 to 0.6.4 (#3164)** (00baff5) - **Bump chrono from 0.4.40 to 0.4.41 (#3174)** (109c6db) - **Bump bytemuck from 1.22.0 to 1.23.0 (#3173)** (6863c6f) - **[ISSUE #3165]🚀Optimize cargo clippy -- -D warnings (#3175)** (f2d0a72) - **Bump tokio-util from 0.7.14 to 0.7.15 (#3160)** (774628e) - **[ISSUE #3154]🚀Implement NotificationProcessor (#3157)** (6abdf71) - **[ISSUE #3150]🚀Implement PopReviveService get_revive_behind_millis and get_revive_behind_messages (#3151)** (d4039e5) - **[ISSUE #3148]🚀Implement PopReviveService#mockCkForAck (#3149)** (d19ae35) - **[ISSUE #3145]⚡️Optimize EscapeBridge#get_message_async method return type (#3146)** (2d3df47) - **[ISSUE #3140]⚡️Implement PopReviveService#revive_msg_from_ck method (#3144)** (3d2b594) - **Bump clap from 4.5.36 to 4.5.37 (#3143)** (2fdaebb) - **Bump rand from 0.9.0 to 0.9.1 (#3142)** (54f4db2) - **Bump proc-macro2 from 1.0.94 to 1.0.95 (#3141)** (0525684) - **[ISSUE #3134]⚡️Optimize AckMessageProcessor#append_ack logic handle (#3135)** (f79c36e) - **[ISSUE #3131]⚡️Optimize ExtraInfoUtil (#3133)** (32dd495) - **Bump libc from 0.2.171 to 0.2.172 (#3132)** (24fee87) - **[ISSUE #3124]🐛Broker not config file started fail (#3125)** (5f095c1) - **[ISSUE #3120]🚀Implement ProducerManager#do_channel_close_event (#3122)** (bfd176f) - **[ISSUE #3119] Implement ProducerManager#scan_not_active_channel (#3121)** (9c57a3d) - **[ISSUE #3117]🚀Implement ProducerManager get_producer_table and call_producer_change_listener (#3118)** (455287a) - **Bump anyhow from 1.0.97 to 1.0.98 (#3112)** (8ccd22b) - **[ISSUE #3110]⚡️Optimize Config file parse (#3111)** (31127fc) - **[ISSUE #3097]♻️Rocketmq error refactor (#3109)** (61a02bb) - **[ISSUE #3096]🚀pub use anyhow::Result as RocketMQResult💫 (#3098)** (35eb65d) - **[ISSUE #3094]⚡️Optimize Channel and ChannelInner💫 (#3095)** (b4240a6) - **Bump clap from 4.5.35 to 4.5.36 (#3093)** (7a1680a) - **[ISSUE #3091]♻️Refactor Channel💫 (#3092)** (3c45dec) - **[ISSUE #3082]🚀Implement ConsumerManager#do_channel_close_event method (#3083)** (2da9cea) - **[ISSUE #3075]🚀ClientManageProcessor supports UnregisterClient(request code:35) (#3079)** (1a7b64f) - **[ISSUE #3077]⚡️Optimize ClientManageProcessor return type (#3078)** (f40e0e4) - **Bump crossbeam-channel from 0.5.14 to 0.5.15 (#3076)** (7d1a6fb) - **[ISSUE #3073]🚀Implement ConsumerManager scan_not_active_channel and remove_expire_consumer_group_info method (#3074)** (91066c8) - **[ISSUE #3071]🚀Implement ConsumerManager#register_consumer_without_sub method (#3072)** (2f90f6c) - **[ISSUE #3069]🚀Implement ConsumerManager#unregisterConsumer method (#3070)** (d1c245a) - **[ISSUE #3067]⚡️Optimize ConsumerManager#register_consumer_ext method (#3068)** (6cbfe6c) - **[ISSUE #3065]🚀Implement ConsumerManager#findChannel (#3066)** (268e035) - **[ISSUE #3063]⚡️Optimize ConsumerManager broker_stats_manager attribute (#3064)** (cab96db) - **[ISSUE #3055]⚡️Optimize ReputMessageServiceInner#do_reput method (#3056)** (8b1363d) - **[ISSUE #3052]🐛PullMessageProcessor zero copy transfer header encode incorrect (#3053)** (52094a1) - **[ISSUE #3050]🐛PopMessageProcessor zero copy transform header encode incorrect (#3051)** (3648acf) - **[ISSUE #3048]🚀Implement· RemotingCommand#header_encode method (#3049)** (a99dbb9) - **[ISSUE #3046]🚀Implement ConsumeQueue#iterate_from_with_count method (#3047)** (f26b04c) - **[ISSUE #3044]⚡️Implement GetMessageResult default trait (#3045)** (d05d176) - **Bump hostname from 0.4.0 to 0.4.1 (#3043)** (89a1240) - **[ISSUE #3041]⚡️Implement Pull message zero copy transform💫 (#3042)** (acb86e6) - **[ISSUE #3039]🚀Implement PopMessageProcessor zero copy transform (#3040)** (fe0c64c) - **[ISSUE #3037]⚡️Optimize SelectMappedBufferResult (#3038)** (4b55f6b) - **[ISSUE #3031]⚡️Replace CompositeCodec BytesMut with Bytes (#3032)** (a091ca1) - **[ISSUE #3029]⚡️Optimize GetMessageResult#add_message and add_message_inner (#3030)** (41af1a5) - **[ISSUE #3027]⚡️Optimize SelectMappedBufferResult#get_bytes method (#3028)** (d168d1a) - **[ISSUE #3025]⚡️Optimize QueueLockManager logic (#3026)** (d4cf625) - **[ISSUE #3023]⚡️Optimize ConsumerOffsetManager#query_offset logic (#3024)** (61bc3db) - **Bump tokio from 1.44.1 to 1.44.2 (#3019)** (eddf0ed) - **[ISSUE #3016]⚡️Optimize QueryAssignmentProcessor#allocate_for_pop💫 (#3017)** (e57cdf1) - **[ISSUE #3014]⚡️Simplify TopicRouteInfoManager#get_topic_subscribe_info💫 (#3015)** (1b43f2b) - **[ISSUE #3000]🚀Optimize util_all#char_to_byte performance💫 (#3001)** (3a57c06) - **[ISSUE #2998]🚀Optimize MappedFileQueue#do_load💫 (#2999)** (ff52cef) - **[ISSUE #2996]🚀Implement MappedFileQueue#check_self method💫 (#2997)** (7c52459) - **[ISSUE #2993]♻️Refactor MappedFileQueue💫 (#2994)** (de1fb2a) - **[ISSUE #2991]⚡️Optimize ConsumeQueue#put_message_position_info💫 (#2992)** (279c27b) - **Bump openssl from 0.10.70 to 0.10.72 (#2990)** (977c036) - **[ISSUE #2988]♻️Refactor ConsumeQueue💫 (#2989)** (5963450) - **[ISSUE #2985]♻️Refactor TopicAttributes💫 (#2986)** (4a02e84) - **[ISSUE #2980]♻️Refactor ConsumeQueueStore💫 (#2982)** (212d2b1) _Recap by [Repo Wrapped](https://repowrapped.com/gh/mxsm/rocketmq-rust?utm_source=github-action)._