|
24 | 24 | import org.apache.rocketmq.common.message.MessageConst; |
25 | 25 | import org.apache.rocketmq.common.message.MessageDecoder; |
26 | 26 | import org.apache.rocketmq.common.message.MessageExt; |
| 27 | +import org.apache.rocketmq.common.message.MessageExtBrokerInner; |
27 | 28 | import org.apache.rocketmq.logging.org.slf4j.Logger; |
28 | 29 | import org.apache.rocketmq.logging.org.slf4j.LoggerFactory; |
29 | | -import org.apache.rocketmq.common.message.MessageExtBrokerInner; |
30 | 30 | import org.apache.rocketmq.store.PutMessageResult; |
31 | 31 | import org.apache.rocketmq.store.PutMessageStatus; |
32 | 32 |
|
33 | | -import java.util.concurrent.ThreadLocalRandom; |
34 | | - |
35 | 33 | public class DefaultTransactionalMessageCheckListener extends AbstractTransactionalMessageCheckListener { |
36 | 34 | private static final Logger log = LoggerFactory.getLogger(LoggerName.TRANSACTION_LOGGER_NAME); |
37 | 35 |
|
@@ -62,15 +60,14 @@ public void resolveDiscardMsg(MessageExt msgExt) { |
62 | 60 |
|
63 | 61 | private MessageExtBrokerInner toMessageExtBrokerInner(MessageExt msgExt) { |
64 | 62 | TopicConfig topicConfig = this.getBrokerController().getTopicConfigManager().createTopicOfTranCheckMaxTime(TCMT_QUEUE_NUMS, PermName.PERM_READ | PermName.PERM_WRITE); |
65 | | - int queueId = ThreadLocalRandom.current().nextInt(99999999) % TCMT_QUEUE_NUMS; |
66 | 63 | MessageExtBrokerInner inner = new MessageExtBrokerInner(); |
67 | 64 | inner.setTopic(topicConfig.getTopicName()); |
68 | 65 | inner.setBody(msgExt.getBody()); |
69 | 66 | inner.setFlag(msgExt.getFlag()); |
70 | 67 | MessageAccessor.setProperties(inner, msgExt.getProperties()); |
71 | 68 | inner.setPropertiesString(MessageDecoder.messageProperties2String(msgExt.getProperties())); |
72 | 69 | inner.setTagsCode(MessageExtBrokerInner.tagsString2tagsCode(msgExt.getTags())); |
73 | | - inner.setQueueId(queueId); |
| 70 | + inner.setQueueId(0); |
74 | 71 | inner.setSysFlag(msgExt.getSysFlag()); |
75 | 72 | inner.setBornHost(msgExt.getBornHost()); |
76 | 73 | inner.setBornTimestamp(msgExt.getBornTimestamp()); |
|
0 commit comments