This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from a7c1d4945 [ISSUE #5356] [RIP 48] Introduces the concept of ready and
inflight messages (#5357)
add d54f8cb1e [ISSUE #5402] not to decompress the body of messages when
get retry messages in PopReviveService (#5403)
No new revisions were added by this update.
Summary of changes:
.../rocketmq/broker/failover/EscapeBridge.java | 8 +-
.../broker/processor/PopReviveService.java | 13 +--
.../rocketmq/broker/failover/EscapeBridgeTest.java | 4 +-
.../{BasePopOrderly.java => BasePopNormally.java} | 45 +++-------
.../test/client/consumer/pop/PopBigMessageIT.java | 100 +++++++++++++++++++++
5 files changed, 124 insertions(+), 46 deletions(-)
copy
test/src/test/java/org/apache/rocketmq/test/client/consumer/pop/{BasePopOrderly.java
=> BasePopNormally.java} (58%)
create mode 100644
test/src/test/java/org/apache/rocketmq/test/client/consumer/pop/PopBigMessageIT.java
