This is an automated email from the ASF dual-hosted git repository. zhouxzhan pushed a commit to branch develop in repository https://gitbox.apache.org/repos/asf/rocketmq.git
commit 1e71cd118e1bcc6dfd0f2034f391ee9fee862f4a Author: zhouxiang <[email protected]> AuthorDate: Thu Nov 24 18:03:37 2022 +0800 [ISSUE #5406] Fix PullMessageActivityTest --- .../rocketmq/proxy/remoting/activity/PullMessageActivityTest.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivityTest.java b/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivityTest.java index 5798e883b..d8ad45187 100644 --- a/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivityTest.java +++ b/proxy/src/test/java/org/apache/rocketmq/proxy/remoting/activity/PullMessageActivityTest.java @@ -106,7 +106,7 @@ public class PullMessageActivityTest extends InitConfigTest { newHeader.setQueueId(0); newHeader.setQueueOffset(0L); newHeader.setMaxMsgNums(16); - newHeader.setSysFlag(PullSysFlag.buildSysFlag(true, false, false, false)); + newHeader.setSysFlag(PullSysFlag.buildSysFlag(true, false, true, false)); newHeader.setCommitOffset(0L); newHeader.setSuspendTimeoutMillis(1000L); newHeader.setSubVersion(0L);
