What are doing now? (I Want You)

[mxsm]

If you are interested in these features and want to contribute, please do not hesitate to contact me.

Broker feature develop

• [Feature]Add Broker bootstrap #140

• [Enhancement] Implementing network communication for the Broker #169

  • [Feature] Implementing network communication for the Broker-1 #170
  • [Feature] Implementing network communication for the Broker-2 #173
  • [Feature] Implementing network communication for the Broker-3 #191

• [Feature] Support send message and send message v2(request code:10,310) #206

  • [Feature] Support send message and send message v2(request code:10,310)-1 #207
  • [Feature] Support send message and send message v2(request code:10,310)-2 #209
  • [Feature] Support send message and send message v2(request code:10,310)-3 #216

• [Feature🚀] Rocketmq-Rust supports the POP consumption model #1297

  • [Feature🚀] Rocketmq-Rust broker supports the POP consumption model #1299

• [Feature🚀] Rocketmq-rust request code QUERY_ASSIGNMENT(400) support #1300

  • [Feature🚀] Rocketmq-rust broker supports request code QUERY_ASSIGNMENT(400)  #1301
    • [Feature🚀] Add QueryAssignmentRequestBody and QueryAssignmentResponseBody #1303

• [Feature🚀] Rocketmq-rust supports Pop consumer #1597

• [Feature🚀] Rocketmq-broker supports RequestCode ChangeMessageInvisibleTime(200053) #1678

  • [Feature🚀]Add PopCheckPoint struct #1679
  • [Refactor♻️]Refactor ChangeInvisibleTimeProcessor handle logic #1680
  • [Feature🚀] Implement ChangeInvisibleTimeProcessor logic #1681
  • [Feature🚀] Implement ChangeInvisibleTimeProcessor#ack_origin method #1691
  • [Feature🚀] Implement ChangeInvisibleTimeProcessor#append_check_point method #1692
  • [Feature🚀]Implement ChangeInvisibleTimeProcessor#process_change_invisible_time_for_order method #1693

• [Feature🚀] Rocketmq-broker supports EscapeBridge functions #1694

  • [Feature🚀] Add EscapeBridge struct for rust #1695
  • [Feature🚀] EscapeBridge supports putMessage #1696
  • [Feature🚀] EscapeBridge supports putMessageToRemoteBroker #1697
  • [Feature🚀] EscapeBridge supports asyncPutMessage #1698
  • [Feature🚀] EscapeBridge supports putMessageToSpecificQueue #1699

Store feature develop

• [Feature]Add rocketmq store config #133

• [Feature]Define rocketmq Message #135

• [Feature]Define the rust version of Messagestore based on the Java version of MessageStore #137

• [Feature]Implementation MessageStore load file data from local file #139

  • [Feature]Add the basic code for local file in the store module #144

• [Feature] Implement DefaultMappedFile related functions #217

  • [Feature] Implement DefaultMappedFile initialization #218

• [Feature] Implement MessageStore put message(single message) #222

  • [Feature] Implement MessageStore put message-1 #220
  • [Feature]Implement MessageStore put message(single message)-2 #223
  • [Feature]Implement MessageStore put message(single message)-3 #227

• [Feature🚀] Rocketmq-rust supports RequestCode ConsumerSendMsgBack(36) #1541

  • [Refactor♻️]Refactor ConsumerSendMsgBackRequestHeader with derive RequestHeaderCodec #1542
  • [Feature🚀] Rocketmq-rust broker supports RequestCode ConsumerSendMsgBack(36) #1546
  • [Feature🚀] Rocketmq-client supports RequestCode ConsumerSendMsgBack(36) #1551

[mxsm]

Namesrv feature develop

KV config manage

• [Feature]Support kv config manage #41
  • [Feature]Support put kv config(request code 100) #40
  • [Feature]Namesrv supports get kv config(request code 101) #60
  • [Feature]Namesrv support delete kv config(request code 102) #62
  • [Feature]Namesrv support get kv list by namespace (request code 219) #84

Broker manager

• [Enhancement]Perfect support broker register(request code 103) #53
• [Feature]Namesrv support broker unregister(request code 104) #57
• [Feature]Namesrv support broker heartbeat(request coe 904) #65
• [Feature]Namesrv support get broker member group(request code 901) #67
• [Feature]Namesrv support get broker cluster info(request code 106)  #68
• [Feature]Client disconnected and deregistered from Broker #115

Perm manage

• [Feature]Namesrv support wipe write perm of boker(request code 205) #74
• [Feature]Namesrv support add write perm of brober (request code 327) #75
• [Feature]Namesrv support get topics by cluster (request code 224)  #85
• [Feature]Namesrv support get system topic list (request code 304)  #86
• [Feature]Namesrv support get unit topic list (request code 311)  #87
• [Feature]Namesrv support get has unit sub topic list (request code 312) #88
• [Feature]Namesrv support get has unit sub ununit topic list (request code 313) #89

Topic manage

• [Feature]Namesrv supports get all topic list from name server(request code 206) #76
• [Feature]Namesrv support delete topic in namesrv (request code 216) #82
• [Feature]Namesrv support register topic in namesrv (request code 217) #83

Namesrv config manage

• [Feature]Namesrv support update namesrv config (request code 318) #90
• [Feature]Namesrv support get namesrv config (request code 319) #91

Others

• [Feature]Namesrv support query data version (request code 322) #64
• [Enhancement] Add Schedule Service to do scan not active broker #100
• [Feature]Add parsing configuration files for Namesrv #107
• [Enhancement⚡️] Optimize ClientRequestProcessor error handle #1552
• [Enhancement⚡️] Optimize rocketmq-namesrv crate DefaultRequestProcessor error handle #1553

macros develop

• [Enhancement]Define macros to handle common code for RequestHeader #129

[mxsm]

Client feature develop

AllocateMessageQueueStrategy algorithm

• [Feature🚀] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMachineRoomNearby #1292
• [Feature🚀] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueAveragelyByCircle #1293
• [Feature🚀] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueByConfig #1294
• [Feature🚀] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueByMachineRoom #1295
• [Feature🚀] Rocketmq-client supports the AllocateMessageQueueStrategy algorithm-AllocateMessageQueueConsistentHash #1296

Message Consume

• [Feature🚀] Rocketmq-Rust supports the POP consumption model #1297
  • [Feature🚀] Rocketmq-Rust client supports the POP consumption model #1298
• [Feature🚀] Rocketmq-rust request code QUERY_ASSIGNMENT(400) support #1300
  • [Feature🚀] Rocketmq-rust broker supports request code QUERY_ASSIGNMENT(400)  #1301
• [Feature🚀] Rocketmq-rust supports Pop consumer #1597
  • [Feature🚀] Rocketmq-client support Pop consumer-1 #1598
  • [Feature🚀] Rocketmq-client support Pop consumer-2 #1599
  • [Feature🚀] Implement DefaultMQPushConsumerImpl#pop_message method #1610
  • [Feature🚀] ClientRemotingProcessor supports RequestCode::ConsumeMessageDirectly(309) #1611
  • [Feature🚀] Implement ConsumeMessageConcurrentlyService#consumeMessageDirectly #1615
  • [Feature🚀] Implement ConsumeMessageOrderlyService#consumeMessageDirectly #1616
  • [Feature🚀] Implement ConsumeMessagePopConcurrentlyService#consumeMessageDirectly #1617
  • [Feature🚀] Implement ConsumeMessagePopOrderlyService#consumeMessageDirectly #1618
  • [Feature🚀] Implement ConsumeMessagePopOrderlyService#submitPopConsumeRequest #1619
  • [Feature🚀] Implement ConsumeMessagePopConcurrentlyService#submitPopConsumeRequest #1620
• [Enhancement⚡️] Optimize MessageListenerConcurrently#consume_message method signature #1674
• [Enhancement⚡️] Optimize MessageListenerOrderly#consume_message method signature #1675
• [Enhancement⚡️] Optimize MessageListenerConcurrentlyFn signature #1676
• [Enhancement⚡️] Optimize MessageListenerOrderlyFn signature #1677

Admin

• [Feature🚀] Add MqClientAdmin trait #1564
  • [Feature🚀] Add GetTopicStatsInfoRequestHeader struct #1565
  • [Feature🚀] Add QueryConsumeTimeSpanRequestHeader struct #1566
  • [Feature🚀] Add DeleteSubscriptionGroupRequestHeader struct #1567
  • [Feature🚀] Add ResetOffsetRequestHeader struct #1568
  • [Feature🚀]Add GetConsumerRunningInfoRequestHeader struct #1569
  • [Feature🚀] Add ConsumeMessageDirectlyResultRequestHeader struct #1570