mxsm/rocketmq-rust

Issues

• [Feature🚀] Implement BrokerOuterAPI#send_message_to_specific_broker logic

  #1709 opened 16 days ago by mxsm
  0

• [Feature🚀] EscapeBridge supports putMessageToRemoteBroker

  #1697 opened 16 days ago by mxsm
  0

• [Enhancement⚡️] Optimize TopicPublishInfo some method logic

  #1703 opened 16 days ago by mxsm
  0

• [Refactor♻️]Refactor QueueFilter trait

  #1705 opened 16 days ago by mxsm
  0

• [Enhancement⚡️] Optimize MessageListenerConcurrentlyFn signature

  #1676 opened 18 days ago by mxsm
  0

• [Enhancement⚡️] Add Channel's method #[inline]

  #1685 opened 17 days ago by mxsm
  0

• [Enhancement⚡️] Add #[inline] for PutMessageResult methods

  #1689 opened 17 days ago by mxsm
  2

• [Feature🚀] EscapeBridge supports putMessage

  #1696 opened 17 days ago by mxsm
  0

• [Feature🚀] Add EscapeBridge struct for rust

  #1695 opened 17 days ago by mxsm
  0

• [Enhancement⚡️] Optimize MessageListenerOrderlyFn signature

  #1677 opened 18 days ago by mxsm
  0

• [Feature🚀] Rocketmq-broker supports EscapeBridge functions

  #1694 opened 17 days ago by mxsm
  0

• [Feature🚀] EscapeBridge supports putMessageToSpecificQueue

  #1699 opened 17 days ago by mxsm
  0

• [Feature🚀] EscapeBridge supports asyncPutMessage

  #1698 opened 17 days ago by mxsm
  0

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

  #1678 opened 17 days ago by mxsm
  0

• [Feature🚀]Implement ChangeInvisibleTimeProcessor#process_change_invisible_time_for_order method

  #1693 opened 17 days ago by mxsm
  0

• [Feature🚀] Implement ChangeInvisibleTimeProcessor#append_check_point method

  #1692 opened 17 days ago by mxsm
  0

• [Feature🚀] Implement ChangeInvisibleTimeProcessor#ack_origin method

  #1691 opened 17 days ago by mxsm
  0

• [Feature🚀] Implement ChangeInvisibleTimeProcessor logic

  #1681 opened 17 days ago by mxsm
  0

• [Refactor♻️]Refactor PopMessageProcessor method handle error

  #1687 opened 17 days ago by mxsm
  0

• [Unit Test🧪] Add unit test for PopAckConstants

  #1684 opened 17 days ago by mxsm
  0

• [Feature🚀]Add PopCheckPoint struct

  #1679 opened 17 days ago by mxsm
  0

• [Refactor♻️]Refactor ChangeInvisibleTimeProcessor handle logic

  #1680 opened 17 days ago by mxsm
  0

• [Enhancement⚡️] Optimize MessageListenerOrderly#consume_message method signature

  #1675 opened 18 days ago by mxsm
  0

• [Enhancement⚡️] Optimize MessageListenerConcurrently#consume_message method signature

  #1674 opened 18 days ago by mxsm
  0

• [Enhancement⚡️] Optimize MQClientInstance#find_broker_address_in_subscribe method signature

  #1671 opened 18 days ago by mxsm
  0

• [Feature🚀] Implement DefaultMQPushConsumerImpl#change_pop_invisible_time_async method logic

  #1670 opened 18 days ago by mxsm
  0

• [Feature🚀] Implement MQClientAPIImpl#changeInvisibleTimeAsync method logic

  #1666 opened 18 days ago by mxsm
  0

• [Feature🚀] Add ChangeInvisibleTimeResponseHeader struct

  #1667 opened 18 days ago by mxsm
  0

• [Feature🚀] Add ChangeInvisibleTimeRequestHeader struct

  #1664 opened 18 days ago by mxsm
  0

• [Feature🚀] Add ConsumeRequest for ConsumeMessagePopConcurrentlyService

  #1648 opened 18 days ago by mxsm
  0

• [Feature🚀] Add AckCallback trait

  #1657 opened 18 days ago by mxsm
  0

• [Feature🚀] Add AckResult struct

  #1658 opened 18 days ago by mxsm
  0

• [Feature🚀] Add AckStatus enum

  #1659 opened 18 days ago by mxsm
  0

• [Feature🚀] Implement ConsumeMessagePopConcurrentlyService#process_consume_result logic

  #1655 opened 18 days ago by mxsm
  0

• [Feature🚀] Add ConsumeRequest for ConsumeMessagePopConcurrentlyService

  #1653 opened 18 days ago by mxsm
  0

• [Feature🚀] Implement ExtraInfoUtil for rust

  #1649 opened 18 days ago by mxsm
  0

• [Refactor♻️]Refactor PeekMessageProcessor#process_request method signature

  #1646 opened 19 days ago by mxsm
  0

• [Refactor♻️]Refactor PollingInfoProcessor#process_request method signature

  #1644 opened 19 days ago by mxsm
  0

• [Refactor♻️]Refactor AckMessageProcessor#process_request method signature

  #1642 opened 19 days ago by mxsm
  0

• [Enhancement⚡️]Add #[inline] for MessageBatch struct method

  #1640 opened 19 days ago by mxsm
  0

• [Enhancement⚡️] Add #[inline] for MessageClientExt struct method

  #1639 opened 19 days ago by mxsm
  0

• [Enhancement⚡️] Add #[inline] for MessageExt struct method

  #1638 opened 19 days ago by mxsm
  0

• [Enhancement⚡️] Add #[inline] for Message struct method

  #1637 opened 19 days ago by mxsm
  0

• [Doc📝] Add doc for ConsumeMessageServiceTrait trait

  #1634 opened 19 days ago by mxsm
  0

• [Feature🚀] Implement ConsumeMessagePopOrderlyService#consumeMessageDirectly

  #1618 opened 19 days ago by mxsm
  0

• [Enhancement⚡️] Remove useless code

  #1631 opened 19 days ago by alax-cat
  0

• [Enhancement⚡️] Replace Client consumer's WeakArcMut<DefaultMQPushConsumerImpl> with ArcMut<DefaultMQPushConsumerImpl>

  #1627 opened 19 days ago by mxsm
  0

• [Enhancement⚡️] Replace ClientRemotingProcessor's WeakArcMut<MQClientInstance> with ArcMut<MQClientInstance>

  #1624 opened 19 days ago by mxsm
  0

• [Feature🚀] Implement ConsumeMessagePopConcurrentlyService#submitPopConsumeRequest

  #1620 opened 20 days ago by mxsm
  0

• [Feature🚀] Implement ConsumeMessagePopOrderlyService#submitPopConsumeRequest

  #1619 opened 20 days ago by mxsm
  0