From 8fb6417d4c57c33205b3eae98e027debcbcbe1c0 Mon Sep 17 00:00:00 2001 From: shilei <798989044@qq.com> Date: Wed, 15 Nov 2023 11:57:49 +0800 Subject: [PATCH] =?UTF-8?q?#EC=5FHJ131#=20=E5=A4=A7=E6=95=B0=E6=8D=AEMQ?= =?UTF-8?q?=E4=BC=98=E5=8C=96?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java | 11 +++++------ 1 file changed, 5 insertions(+), 6 deletions(-) diff --git a/src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java b/src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java index 64a9a580..56bfa561 100644 --- a/src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java +++ b/src/weaver/interfaces/dito/mq/HrmRocketmqServlet.java @@ -69,8 +69,6 @@ public class HrmRocketmqServlet extends HttpServlet { if(StringUtils.isNotBlank(hostAddress) && StringUtils.isNotBlank(hostAddress) && hostAddress.equals(hrmMqRunIP)){ bb.writeLog("initData"); initData(); - - } // if (isMainIp) { @@ -119,7 +117,8 @@ public class HrmRocketmqServlet extends HttpServlet { // String instanceName = propBean.getUfPropValueStatic("instanceName"); // bb.writeLog("instanceName:" + instanceName); consumer.setInstanceName(hrmInstanceName); - consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_LAST_OFFSET); + consumer.setConsumeFromWhere(ConsumeFromWhere.CONSUME_FROM_FIRST_OFFSET); + // String topic = propBean.getUfPropValueStatic("topic"); // String subExpression = propBean.getUfPropValueStatic("subExpression"); // bb.writeLog("topic:" + topic); @@ -139,9 +138,9 @@ public class HrmRocketmqServlet extends HttpServlet { consumer.setClusterName(hrmMQClusterName); consumer.setTenantID(hrmMQTenantID); -// consumer.setConsumeThreadMin(1); -// consumer.setConsumeThreadMax(1); -// consumer.setConsumeMessageBatchMaxSize(1); + consumer.setConsumeThreadMin(1); + consumer.setConsumeThreadMax(1); + consumer.setConsumeMessageBatchMaxSize(1); consumer.setMessageModel(MessageModel.CLUSTERING); consumer.registerMessageListener(new HrmRocketMsgListener3());