Skip to content

Commit c046404

Browse files
authored
[ISSUE-#4251]Add batch flag (#4252)
* Add it test holder for manual test * Add it test holder for manual test * Polish the test, remove useless code * Polish the test, remove useless code * Mark the flag for batch to avoid conflict
1 parent 7043211 commit c046404

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

common/src/main/java/org/apache/rocketmq/common/sysflag/MessageSysFlag.java

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -39,6 +39,9 @@ public class MessageSysFlag {
3939
public final static int TRANSACTION_ROLLBACK_TYPE = 0x3 << 2;
4040
public final static int BORNHOST_V6_FLAG = 0x1 << 4;
4141
public final static int STOREHOSTADDRESS_V6_FLAG = 0x1 << 5;
42+
//Mark the flag for batch to avoid conflict
43+
public final static int NEED_UNWRAP_FLAG = 0x1 << 6;
44+
public final static int INNER_BATCH_FLAG = 0x1 << 7;
4245

4346
// COMPRESSION_TYPE
4447
public final static int COMPRESSION_LZ4_TYPE = 0x1 << 8;

0 commit comments

Comments
 (0)