opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-29 17:25:35 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix mac 12+ slow bug (#4010)

Browse Source
This commit is contained in:
刘月财
2022-04-11 09:29:30 +08:00
committed by GitHub
parent 47561bdd85
commit ead6274b3e
1 changed files with 5 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/org/apache/rocketmq/broker/processor/ReplyMessageProcessor.java
+5 -2
View File
@@ -45,6 +45,7 @@ import org.apache.rocketmq.store.MessageExtBrokerInner;
import org.apache.rocketmq.store.PutMessageResult;
import org.apache.rocketmq.store.stats.BrokerStatsManager;
import java.net.InetSocketAddress;
import java.util.concurrent.ThreadLocalRandom;
public class ReplyMessageProcessor extends AbstractSendMessageProcessor implements NettyRequestProcessor {
@@ -157,8 +158,10 @@ public class ReplyMessageProcessor extends AbstractSendMessageProcessor implemen
final SendMessageRequestHeader requestHeader,
final Message msg) {
ReplyMessageRequestHeader replyMessageRequestHeader = new ReplyMessageRequestHeader();
replyMessageRequestHeader.setBornHost(ctx.channel().remoteAddress().toString());
replyMessageRequestHeader.setStoreHost(this.getStoreHost().toString());
InetSocketAddress bornAddress = (InetSocketAddress)(ctx.channel().remoteAddress());
replyMessageRequestHeader.setBornHost(bornAddress.getAddress().getHostAddress() + ":" + bornAddress.getPort());
InetSocketAddress storeAddress = (InetSocketAddress)(this.getStoreHost());
replyMessageRequestHeader.setStoreHost(storeAddress.getAddress().getHostAddress() + ":" + storeAddress.getPort());
replyMessageRequestHeader.setStoreTimestamp(System.currentTimeMillis());
replyMessageRequestHeader.setProducerGroup(requestHeader.getProducerGroup());
replyMessageRequestHeader.setTopic(requestHeader.getTopic());