[rocketmq] branch pop_consumer updated (ea36854 -> d3d0207)

[du...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch pop_consumer
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from ea36854  Merge pull request #2733 from ayanamist/pop_consumer
     new ced6b02  [RIP-19] Pop Consuming (broker)
     new f868d99  Init pop retry consumer offset when create
     new d54629c  Add abbreviation for fields of PopCheckPoint to save commit log size.
     new d3d0207  Merge pull request #2757 from ayanamist/dev_pop_consume

The 1512 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 broker/pom.xml                                     |   4 +
 .../apache/rocketmq/broker/BrokerController.java   | 154 +++-
 .../rocketmq/broker/BrokerPathConfigHelper.java    |   8 +
 .../broker/loadbalance/AssignmentManager.java      | 149 ++++
 .../loadbalance/MessageRequestModeManager.java     |  99 +++
 .../longpolling/NotifyMessageArrivingListener.java |   9 +-
 .../rocketmq/broker/longpolling/PopRequest.java    |  87 ++
 .../broker/offset/ConsumerOrderInfoManager.java    | 426 +++++++++
 .../apache/rocketmq/broker/out/BrokerOuterAPI.java |  42 +-
 .../broker/processor/AckMessageProcessor.java      | 188 ++++
 .../processor/ChangeInvisibleTimeProcessor.java    | 195 +++++
 .../broker/processor/PopBufferMergeService.java    | 731 ++++++++++++++++
 .../broker/processor/PopMessageProcessor.java      | 967 +++++++++++++++++++++
 .../broker/processor/PopReviveService.java         | 470 ++++++++++
 .../broker/processor/QueryAssignmentProcessor.java | 307 +++++++
 .../org/apache/rocketmq/broker/util/MsgUtil.java}  |  14 +-
 ...essorTest.java => AckMessageProcessorTest.java} |  94 +-
 ....java => ChangeInvisibleTimeProcessorTest.java} |  97 +--
 .../processor/PopBufferMergeServiceTest.java       | 108 +++
 ...essorTest.java => PopMessageProcessorTest.java} | 166 ++--
 .../processor/QueryAssignmentProcessorTest.java    | 153 ++++
 .../rebalance/AllocateMessageQueueAveragely.java   |  12 +-
 .../AllocateMessageQueueAveragelyByCircle.java     |  12 +-
 distribution/conf/logback_broker.xml               |  29 +
 pom.xml                                            |   7 +-
 .../rocketmq/remoting/common/RemotingHelper.java   |   9 +-
 .../apache/rocketmq/store/pop/PopCheckPoint.java   |  11 +
 27 files changed, 4309 insertions(+), 239 deletions(-)
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/loadbalance/AssignmentManager.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/loadbalance/MessageRequestModeManager.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/longpolling/PopRequest.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/offset/ConsumerOrderInfoManager.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/AckMessageProcessor.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/ChangeInvisibleTimeProcessor.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/PopBufferMergeService.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/PopMessageProcessor.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/PopReviveService.java
 create mode 100644 broker/src/main/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessor.java
 copy broker/src/{test/java/org/apache/rocketmq/broker/util/LogTransactionalMessageCheckListener.java => main/java/org/apache/rocketmq/broker/util/MsgUtil.java} (57%)
 copy broker/src/test/java/org/apache/rocketmq/broker/processor/{ReplyMessageProcessorTest.java => AckMessageProcessorTest.java} (61%)
 copy broker/src/test/java/org/apache/rocketmq/broker/processor/{ReplyMessageProcessorTest.java => ChangeInvisibleTimeProcessorTest.java} (60%)
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/processor/PopBufferMergeServiceTest.java
 copy broker/src/test/java/org/apache/rocketmq/broker/processor/{PullMessageProcessorTest.java => PopMessageProcessorTest.java} (50%)
 create mode 100644 broker/src/test/java/org/apache/rocketmq/broker/processor/QueryAssignmentProcessorTest.java