提交 c95a1090 编写于 作者: V vongosling

Minor polish

上级 0f3b492f
...@@ -261,7 +261,7 @@ public class DefaultMQPullConsumerImpl implements MQConsumerInner { ...@@ -261,7 +261,7 @@ public class DefaultMQPullConsumerImpl implements MQConsumerInner {
null null
); );
this.pullAPIWrapper.processPullResult(mq, pullResult, subscriptionData); this.pullAPIWrapper.processPullResult(mq, pullResult, subscriptionData);
//If namespace not null , reset Topic without namespace. //If namespace is not null , reset Topic without namespace.
this.resetTopic(pullResult.getMsgFoundList()); this.resetTopic(pullResult.getMsgFoundList());
if (!this.consumeMessageHookList.isEmpty()) { if (!this.consumeMessageHookList.isEmpty()) {
ConsumeMessageContext consumeMessageContext = null; ConsumeMessageContext consumeMessageContext = null;
......
...@@ -97,7 +97,7 @@ public class PullAPIWrapper { ...@@ -97,7 +97,7 @@ public class PullAPIWrapper {
for (MessageExt msg : msgListFilterAgain) { for (MessageExt msg : msgListFilterAgain) {
String traFlag = msg.getProperty(MessageConst.PROPERTY_TRANSACTION_PREPARED); String traFlag = msg.getProperty(MessageConst.PROPERTY_TRANSACTION_PREPARED);
if (traFlag != null && Boolean.parseBoolean(traFlag)) { if (Boolean.parseBoolean(traFlag)) {
msg.setTransactionId(msg.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX)); msg.setTransactionId(msg.getProperty(MessageConst.PROPERTY_UNIQ_CLIENT_MESSAGE_ID_KEYIDX));
} }
MessageAccessor.putProperty(msg, MessageConst.PROPERTY_MIN_OFFSET, MessageAccessor.putProperty(msg, MessageConst.PROPERTY_MIN_OFFSET,
......
...@@ -17,7 +17,7 @@ ...@@ -17,7 +17,7 @@
package org.apache.rocketmq.common.sysflag; package org.apache.rocketmq.common.sysflag;
public class PullSysFlag { public class PullSysFlag {
private final static int FLAG_COMMIT_OFFSET = 0x1 << 0; private final static int FLAG_COMMIT_OFFSET = 0x1;
private final static int FLAG_SUSPEND = 0x1 << 1; private final static int FLAG_SUSPEND = 0x1 << 1;
private final static int FLAG_SUBSCRIPTION = 0x1 << 2; private final static int FLAG_SUBSCRIPTION = 0x1 << 2;
private final static int FLAG_CLASS_FILTER = 0x1 << 3; private final static int FLAG_CLASS_FILTER = 0x1 << 3;
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册